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