我在windows机器上使用kafka,并尝试使用文件源连接器从文件到kafka主题生成内容。首先我启动了zookeeper,然后在启动kafka standalone connector时启动了kafka服务器(第3步),我收到了大量警告、反射异常和错误日志。
我对此没有什么怀疑:
1我需要添加一些jar文件吗?
2在libs文件夹下的kafka dir中有一些jar文件,我需要将它们添加到类路径吗?
任何线索都将不胜感激。
我在windows机器上使用kafka,并尝试使用文件源连接器从文件到kafka主题生成内容。首先我启动了zookeeper,然后在启动kafka standalone connector时启动了kafka服务器(第3步),我收到了大量警告、反射异常和错误日志。
我对此没有什么怀疑:
1我需要添加一些jar文件吗?
2在libs文件夹下的kafka dir中有一些jar文件,我需要将它们添加到类路径吗?
任何线索都将不胜感激。
1条答案
按热度按时间gg58donl1#
我想你可以忽略关于类加载器的消息。
真正的错误信息是找不到您的文件
关于修复批处理脚本中java变量的引号有一些jira问题,这将修复类路径和jar查找问题,但正如我所评论的,最好使用生产级日志转发器将文件读取到kafka