Confluent 3.0.1 with Kafka 0.10.1.0

[Diego Irismar da Costa]

I'm testing a really simple kafka streams spring boot app using the last kafka release.

My dependencies are: 

<confluent.version>3.0.1</confluent.version>

<kafka.version>0.10.1.0</kafka.version>

For some reason, when a start my spring boot It seems that the versions os client and broker are not compatible: 

at the app: 

 org.apache.kafka.clients.NetworkClient   : Bootstrap broker localhost:9092 disconnected

at the broker:

[2016-10-31 09:55:56,422] ERROR Closing socket for 127.0.0.1:9092-127.0.0.1:53590 because of error (kafka.network.Processor)

kafka.network.InvalidRequestException: Error getting request for apiKey: 3 and apiVersion: 2

at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:95)

at kafka.network.RequestChannel$Request.<init>(RequestChannel.scala:87)

at kafka.network.Processor$$anonfun$processCompletedReceives$1.apply(SocketServer.scala:488)

at kafka.network.Processor$$anonfun$processCompletedReceives$1.apply(SocketServer.scala:483)

at scala.collection.Iterator$class.foreach(Iterator.scala:893)

at scala.collection.AbstractIterator.foreach(Iterator.scala:1336)

at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)

at scala.collection.AbstractIterable.foreach(Iterable.scala:54)

at kafka.network.Processor.processCompletedReceives(SocketServer.scala:483)

at kafka.network.Processor.run(SocketServer.scala:413)

at java.lang.Thread.run(Thread.java:745)

Caused by: java.lang.IllegalArgumentException: Invalid version for API key 3: 2

at org.apache.kafka.common.protocol.ProtoUtils.schemaFor(ProtoUtils.java:31)

at org.apache.kafka.common.protocol.ProtoUtils.requestSchema(ProtoUtils.java:44)

at org.apache.kafka.common.protocol.ProtoUtils.parseRequest(ProtoUtils.java:60)

at org.apache.kafka.common.requests.MetadataRequest.parse(MetadataRequest.java:96)

at org.apache.kafka.common.requests.AbstractRequest.getRequest(AbstractRequest.java:48)

at kafka.network.RequestChannel$Request.liftedTree2$1(RequestChannel.scala:92)

Any light on it ? 

tks

[Damian Guy]

Hi,

It looks like the Kafka broker is running 0.10.0.x and Kafka Streams is using 0.10.1.0 - they aren't compatible. 

So, if you want to run Kafka Streams 0.10.1.0 then you will need to make sure your broker is also running 0.10.1.0.

Also: Confluent version 3.0.1 is using AK 0.10.0.1, so this might be the reason you have a discrepancy.  

Thanks,

Damian

  

--
You received this message because you are subscribed to the Google Groups "Confluent Platform" group.
To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platf...@googlegroups.com.
To post to this group, send email to confluent...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/confluent-platform/4e18d666-8d66-4292-95f2-b4cf377233ec%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

[Diego Irismar da Costa]

Thanks Damian ... I didn't notice that The Compatibility Matrix also shows that 

To unsubscribe from this group and stop receiving emails from it, send an email to confluent-platform+unsub...@googlegroups.com.