Open suizman opened 8 years ago
It looks like the solution is as simple as changing kafka_version
in pom.xml
to be the version of Kafka you're using. I changed it to "0.10.1.1" and the next build worked without error.
I am using confluent 2.0.0 version , and getting following error while starting the service java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.KafkaConsumer.subscribe(Ljava/util/List;Lorg/apache/kafka/clients/consumer/ConsumerRebalanceListener;)V at org.apache.kafka.connect.runtime.WorkerSinkTask.joinConsumerGroupAndStart(WorkerSinkTask.java:143) at org.apache.kafka.connect.runtime.WorkerSinkTaskThread.execute(WorkerSinkTaskThread.java:54) at org.apache.kafka.connect.util.ShutdownableThread.run(ShutdownableThread.java:82)
Kafka version used in pom.xml is 0.10.1.1
Sorry, my previous comment here was completely incorrect, I don't know how I could possibly have thought it worked when there are definitely SDK changes between 0.9 and 0.10.
However, Kafka 0.10.1.1 is now supported by the master branch of the project.
Also, please keep in mind that Kafka 0.10.0 and 0.10.1 have incompatible protocols. If you are using Kafka 0.10.0 on your server, you need to run Kafka 0.10.0 client as well.
@RobinDaugherty you can force kafka server to use old protocols with this 2 params in "server.properties":
inter.broker.protocol.version=0.10.0
log.message.format.version=0.10.0
Anyways i'll try the master this weekend :D
@suizman will those affect the protocol used by a producer (like Kafka Connect) connecting to a Kafka broker?
@RobinDaugherty yes, but Kafka Connect producer should be capable of writing the messages with the new 0.10.0+ format
I'm trying to run the plugin against Kafka 0.10.0.1 and i'm getting this error:
It seems that "org.apache.kafka.common.config.ConfigDef.define" method is missing in the new version..