当前位置: 首页 > 知识库问答 >
问题:

当plugin.path有逗号分隔的值时,Kafka connect抛出ClassNotFoundException

澹台承
2023-03-14

我正在使用Kafka connect创建MQTT Kafka连接。我将从confluent站点下载的所有kafka MQTT连接器特定jar放到“/data”文件夹中。并相应地更新“connectstandalone.properties”文件以反映插件路径,即

plugin.path=/opt/kafka_2.11-2.1.1/libs,/data

当我运行Kafka Connect时

./connect-standalone.sh ../config/connect-standalone.properties ../config/connect-mqtt-source.properties

我收到以下错误:

[2019-07-18 10:26:05,823]信息加载插件from:/data/Kafka-connect-mqtt-1 . 2 . 1 . jar(org . Apache . Kafka . connect . runtime . isolation . delegating class loader:220)[2019-07-18 10:26:05,829]因出错而停止(org . Apache . Kafka . connect . CLI . connect standalone:128)Java . lang . NOC

请注意,“connect-utils-0.3.140.jar”存在于“/data”文件夹中,如红色下划线突出显示。

现在,如果我在下面制作一个软链接截图,或者从“/data”文件夹中复制所有的jar,并将插件路径更新为:

plugin.path=/opt/kafka_2.11-2.1.1/libs

Kafka连接非常好。

为什么它在第一种情况下不起作用的任何帮助,即不同文件夹中的Kafka连接器特定罐子

共有1个答案

戈宏义
2023-03-14

从Confluent页面上的Kafka Connect用户指南:

...

Kafka Connect将每个插件彼此隔离,这样一个插件中的库就不会受到其他插件中库的影响。当混合和匹配来自多个提供商的连接器时,这一点非常重要。

Kafka Connect插件是:

  1. 一个包含插件的所有类文件及其第三方依赖关系的uberJAR文件;或
  2. 文件系统上的一个目录,其中包含插件及其第三方依赖项的JAR文件

在您的情况下,您必须将插件jar放在一个文件夹中,例如/data/pluginName,而不是直接放在/data/

更多细节可以在这里找到:安装插件

 类似资料:
  • 问题内容: 我正在编写导出功能,我需要将联系人导出到Excel,并且遇到了技术难题-也许我的SQL技能的差距更接近事实了。;) 这是场景:我在数据库中有一堆联系人。每个联系人可以具有许多不同的角色,例如,一个联系人可以是C#开发人员和DBA,也可以是DBA和IT经理。它们分为三个表,如下所示: 不太难遵循。有一组联系人和一组角色。这些由相应ID上的ContactRole表连接。 导出联系人时,我需

  • 问题内容: 我的数据库中有列,其中的值如下所示: 在虚拟列中没有任何编号。逗号分隔的值可以出现。我尝试了以下查询,但它正在创建重复的结果。 我不明白这个问题。谁能帮忙? 问题答案: 非常适合我- 还有许多其他方法可以实现它。阅读将单个逗号分隔的字符串拆分成行。 *关于使用列而不是单个字符串值时的重复项的 *更新 。只见PRIOR子句中使用DBMS_RANDOM的摆脱循环回路的在这里 尝试以下方法

  • 我如何修改我的regex来为那些以“”或“,”开头,以“”或“,”结尾的字符串返回false

  • 问题内容: 我有看起来像的数据 我想编写一个查询,使数据看起来像这样: 如果有帮助,请使用Oracle 10g。我看到了一些可以使用MYSQL正常工作的东西,但是我需要一个普通的SQL或ORACLE等效项。我也看到了可以制作存储过程的示例,但是,我不能将存储过程与正在使用的产品一起使用。 如果我正在使用它,这是如何在MySQL中工作的 谢谢你。 问题答案: 该链接引用了许多在Oracle上执行此操

  • 问题内容: 我有2张桌子和。表包含客户的电子邮件。 我正在使用PHP-IMAP从电子邮件服务器获取电子邮件,然后将其保存到数据库表。 该表有2个字段,并且字段包含逗号分隔的值。 我需要获取从第一台邮件,然后搜索对与上。 首先,我考虑了要搜索的条件,但我想拥有类似的东西或其他东西。 我怎样才能更好地做到这一点?(由于某些原因,我无法在此表上使用关系) 请指教。 问题答案: 基于FIND_IN_SET

  • 问题内容: 我有一个非常基本的场景(Angular有点新)。我正在尝试转换JSON: 至: 但我不知道如何生成单个“ p”。您怎么称呼ng-repeat 问题答案: 有用的一件事是创建一个“地图”过滤器,如下所示: 这是映射到命名属性的简单情况,您可以使其更加花哨并理解点表示法等。现在,在您的视图中,您可以执行以下操作: 因为地图过滤器返回一个Array,该数组在Javascript中已经具有内置