无法启动 Kafka-Connect

Question

我在使用命令“./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka-connect-elasticsearch/quickstart-”启动 kafka-connect 时遇到以下错误elasticsearch.properties”。因此 kafka-connect 无法正常启动。

[2017-11-02 18:03:12,852] DEBUG could not scan file org/apache/commons/codec/language/bm/gen_rules_russian.txt in url file:/apps/confluent/confluent-3.3.0/share/java/kafka-connect-elasticsearch/commons-codec-1.9.jar with scanner TypeAnnotationsScanner (org.reflections.Reflections:257)
org.reflections.ReflectionsException: could not create class object from file org/apache/commons/codec/language/bm/gen_rules_russian.txt
at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:32)
at org.reflections.Reflections.scan(Reflections.java:253)
at org.reflections.Reflections.scan(Reflections.java:202)
at org.reflections.Reflections.<init>(Reflections.java:123)
at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:221)
        at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:198)
        at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:190)
        at org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:150)
        at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:47)
        at org.apache.kafka.connect.cli.ConnectStandalone.main(ConnectStandalone.java:68)
Caused by: org.reflections.ReflectionsException: could not create class file from gen_rules_russian.txt
        at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:102)
        at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:24)
        at org.reflections.scanners.AbstractScanner.scan(AbstractScanner.java:30)
        ... 9 more
Caused by: java.io.IOException: bad magic number: 2f2a0a20
        at javassist.bytecode.ClassFile.read(ClassFile.java:825)
        at javassist.bytecode.ClassFile.<init>(ClassFile.java:154)
        at org.reflections.adapters.JavassistAdapter.getOfCreateClassObject(JavassistAdapter.java:100)
        ... 11 more

下面是 connect-standalone.properties 文件的内容：

bootstrap.servers=dc2vmtkafmq01:9092
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=false
value.converter.schemas.enable=false
internal.key.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter=org.apache.kafka.connect.json.JsonConverter
internal.key.converter.schemas.enable=false
internal.value.converter.schemas.enable=false
offset.storage.file.filename=/tmp/connect.offsets
offset.flush.interval.ms=1000
rest.host.name=dc2vmtkafmq01
rest.port=8083
plugin.path=/apps/confluent/confluent-3.3.0/share/java/kafka-connect-elasticsearch

下面是 quickstart-elasticsearch.properties 文件的内容：

name=elasticsearch-sink
connector.class=io.confluent.connect.elasticsearch.ElasticsearchSinkConnector
tasks.max=2
topics=compositionlog
topic.index.map=compositionlog:compositionlog
connection.url=http://10.104.185.143:9200
type.name=traceentity
key.ignore=true
schema.ignore=true

知道可能是什么问题吗？

Answer 1

Java 版本似乎有问题 - 请确保使用正确的版本 - Java 8。

详细规格在official documentation。