2017-11-02 14 views
0

"./bin/connect-standalone ./etc/kafka/connect-standalone.properties ./etc/kafka"コマンドでkafka-connectを起動すると、次のエラーが表示されます。 -connect-elasticsearch/quickstart-elasticsearch.properties」を参照してください。そのため、kafka-connectは正しく起動できません。以下は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 

についての任意のアイデア何が問題なの?

答えて

2

これは、Javaのバージョンの問題のように見える - あなたは正しいものを使用していることを確認してください - Javaの8

詳細なスペックはofficial documentationです。