AWS MSK。 Kafka Connect - 插件类加载
我正在使用MSK中的Kafka Connect。
我已经定义了一个指向S3中的zip文件的插件 - 这可以正常工作。
我已经实现了 smt强>相同的存储夹和文件夹与插件的zip文件。 我定义了一个新的连接器，这次我使用
transforms
我收到一条错误消息，即找不到类com.xyzmysmt找不到的错误消息。 我验证了罐子有效并包含SMT。 我应该在哪里放置smt jar才能使卡夫卡连接加载？
I am using Kafka Connect in MSK.
I have defined a plugin that points to a zip file in s3 - this works fine.
I have implemented SMT and uploaded the SMT jar into the same bucket and folder as the zip file of the plugin.
I define a new connector and this time I add the SMT using
transforms
I get an error message that the Class com.x.y.z.MySMT could not be found.
I verified that the jar is valid and contains the SMT.
Where should I put the SMT jar in order to make Kafka connect loading it?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
将SMT罐推入拉链（ /lib）中，解决了未发现的类别的类。
Pushing the SMT jar into the zip (under /lib) solved the class not found issue.