我想使用源代码启动Kafka连接器

Question

我想使用源代码启动Kafka连接器，但总是遇到一些错误。

这是我的配置，不知道是不是我配置的方式有问题

以下是一些错误消息。

[2023-09-12 17:04:22,050] INFO Scanning for plugin classes. This might take a moment ... (org.apache.kafka.connect.cli.ConnectStandalone)
[2023-09-12 17:04:24,566] INFO Reflections took 2369 ms to scan 85 urls, producing 7787 keys and 30651 values [using 8 cores] (org.reflections.Reflections)
[2023-09-12 17:04:24,584] WARN could not get type for name org.eclipse.swt.events.ControlListener from any class loader (org.reflections.Reflections)
org.reflections.ReflectionsException: could not get type for name org.eclipse.swt.events.ControlListener
    at org.reflections.ReflectionUtils.forName(ReflectionUtils.java:312)
    at org.reflections.Reflections.expandSuperTypes(Reflections.java:382)
    at org.reflections.Reflections.<init>(Reflections.java:140)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader$InternalReflections.<init>(DelegatingClassLoader.java:490)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:363)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:298)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:248)
    at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:241)
    at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:60)
    at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:78)

Answer 1

尝试直接使用源代码只会导致问题

connect-standalone.sh

调用

kafka-run-class.sh

，后者又设置 JVM 实际运行 ConnectStandalone Java 类所需的必要 CLASSPATH。

尝试从 IDE 运行代码将导致与 IDE 的类路径冲突