我需要别人的帮助。
我遵循一个教程，使用kafka connect和debezium将数据从mysql流到kafka，但是我在使用debezium mysql connector将mysql连接到kafka服务器时遇到了问题。
这是我的设置和其他信息。
操作系统：Windows10。
Kafka连接：汇合5.0。
mysql连接器：0.8.1 final。
我保存文件
.
我添加插件路径
当我尝试连接到kafka connect时，它返回了一个错误。”找不到任何实现连接器且名称与io.debezium.connector.mysql.mysqlconnector匹配的类“
我错过什么了吗？有人能帮忙吗？
2条答案
按热度按时间jaxagkaj1#
你的插件路径是错误的（confluent-5.0.0\share\java），要么它应该以/（表示当前驱动器的根目录）开头，要么你应该给出完整的路径。
这就是连接器jar不在类路径中的原因
iugsix8n2#
确保已将.jar连接器文件放在
plugins.path它在kafka connect属性中定义，通常Map到/usr/share/java.将连接器添加到正确的目录下后，您需要加载连接器或重新启动kafka connect，以便在启动时自动加载连接器。