Kafka-Connect를 시작할 수 없습니다.

Question

"./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka"명령으로 kafka-connect를 시작하는 동안 다음 오류가 나타납니다. -connect-elasticsearch/quickstart-elasticsearch.properties "를 참조하십시오. 따라서 kafka-connect를 제대로 시작할 수 없습니다.

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 

모든 아이디어에 대해 : 아래

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 파일의 내용입니다 : 아래

[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 파일의 내용입니다 무엇이 문제 일 수 있겠습니까? 자바 8.

자세한 사양 official documentation에 - 당신이 올바른 사용하는 것이 확인하십시오 -

Answer 1

그것은 자바 버전과 문제처럼 보인다.