Hi folks,
I try to start the kafka connect in the distribute ways as follows. It has
below error. Standalone mode is fine. It happens on the 3.0.1. and 3.1 version
of confluent kafka. Des anyone know the cause of this error?
Thanks,
Will
security.protocol = PLAINTEXT
internal.key.converter = class
org.apache.kafka.connect.json.JsonConverter
access.control.allow.methods =
ssl.keymanager.algorithm = SunX509
metrics.sample.window.ms = 30000
(org.apache.kafka.connect.runtime.distributed.DistributedConfig:178)
[2016-12-05 21:24:14,457] INFO Logging initialized @991ms
(org.eclipse.jetty.util.log:186)
Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to
construct kafka consumer
at
org.apache.kafka.connect.runtime.distributed.WorkerGroupMember.<init>(WorkerGroupMember.java:125)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.<init>(DistributedHerder.java:148)
at
org.apache.kafka.connect.runtime.distributed.DistributedHerder.<init>(DistributedHerder.java:130)
at
org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:84)
Caused by: java.lang.NoSuchMethodError:
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.<init>(Lorg/apache/kafka/clients/consumer/internals/ConsumerNetworkClient;Ljava/lang/String;IIILorg/apache/kafka/common/metrics/Metrics;Ljava/lang/String;Lorg/apache/kafka/common/utils/Time;J)V
at
org.apache.kafka.connect.runtime.distributed.WorkerCoordinator.<init>(WorkerCoordinator.java:77)
at
org.apache.kafka.connect.runtime.distributed.WorkerGroupMember.<init>(WorkerGroupMember.java:105)
... 3 more
