Kafka Connect添加MySqlConntor失败
我需要某人的帮助。
我遵循教程使用Kafka Connect和Debezium将数据从MySQL流式传输到Kafka，但是使用Debezium MySQL连接器将MySQL连接到Kafka服务器时遇到了麻烦。
这是我的设置和其他信息。
操作系统：视窗10。
Kafka连接:合流5.0。
MySQL连接器：0.8.1最终版本。
我保存文件
我添加插件路径
当我尝试连接Kafka Connect时，它返回了一个错误。“找不到实现连接器且名称与io.debezium.Connector.mysql.MySqlConnector匹配的任何类”
我错过了什么吗？有人能帮忙吗？
共有2个答案
您的插件路径是错误的（confluent-5.0.0\share\java），要么它应该以 / 开头（这意味着当前驱动器的根），要么你应该提供完整的路径。
这就是类路径中不存在连接器jar的原因
确保您已经将。在kafka-connect属性中定义的< code>plugins.path下的jar连接器文件，通常映射到< code>/usr/share/java。
在正确的目录下添加连接器后，您需要加载连接器或重新启动 kafka-connect，以便在启动时自动加载它。
-
我得到了“ExecutorLostFailure（Executor1 lost）”。 我已经尝试了大部分的Spark调优配置。我已经减少到一个执行人失去，因为最初我得到了像6个执行人失败。 以下是我的配置（我的spark-submit）：
-
问题内容： 当页面上只有一个目标div（包含renderer.domElement）时，我的Three.js脚本运行良好。只要在目标div上方添加另一个具有固定高度和宽度的div，ray.intersectObjects就会返回null。我怀疑我为ray创建的向量会引起问题。这是代码。 关于如何解决此问题的任何想法。 编辑：现在是 （three.js r.56） 问题答案： 简短的答案是您必须考虑
-
我参考了以下链接来了解Kafka的HDFS连接https://docs.confluent.io/2.0.0/Connect/connect-hdfs/docs/index.html 我能够通过配置单元集成将数据从Kafka导出到HDFS。 现在我正尝试在Java程序的帮助下将avro记录写入Kafka 当我把Avro记录写到Kafka主题时，我在Connect中出现以下错误
-
问题内容： 我想创建由Cordova 3.1.0驱动的跨平台应用程序，该应用程序是通过Node.js安装的。我已经安装了Visual Studio 2012和Windows Phone SDK 8 +更新。我还添加了 我在环境变量中的路径如下所示： 我已经通过命令创建了应用程序： 我添加了Android平台： 我可以构建一些Android应用。但是Windows Phone 7 / WP 8存在一
-
问题内容： 我正在使用userena并将以下行添加到我的模型中 在注册表格上点击“提交”按钮后，出现以下错误： 我的问题是此错误是什么意思，这与Userena有关吗？ 问题答案： 你必须创建一个迁移，在其中将为新字段指定默认值，因为你不希望它为null。如果不需要null，则只需添加并创建并运行迁移。
-
我遇到以下错误 异常发送上下文初始化事件到org.springframework.web.context.类的监听器实例ContextLoaderListener：org.springframework.beans.factory.BeanCreation异常：创建名为“userAuditLogAspect”的bean时出错：自动构建依赖项的注入失败；嵌套异常org.springframework