This looks like the error that occurs when you use the 0.10 client with an 0.9 broker. The broker needs to be upgraded first. Jeyhun, what versions are you running?
(I sincerely hope this error message will be improved next time there are wire protocol changes!) -Peter > On Jun 14, 2016, at 4:19 AM, Eno Thereska <eno.there...@gmail.com> wrote: > > HI Jeyhun, > > What version of Kafka are you using? > > I haven't run this using Eclipse, but could you try building and running from > the command line (instead of from within Eclipse) as described in that > quickstart document? Does that work? > > Thanks > Eno > >> On 13 Jun 2016, at 20:27, Jeyhun Karimov <je.kari...@gmail.com> wrote: >> >> Hi Community, >> >> I am new to kafka-streams and trying to run WordCount example. >> I get this error whatever I do: >> >> Exception in thread "StreamThread-1" >> org.apache.kafka.common.protocol.types.SchemaException: Error reading field >> 'topic_metadata': Error reading array of size 1209204, only 46 bytes >> available >> >> at org.apache.kafka.common.protocol.types.Schema.read(Schema.java:73) >> >> at org.apache.kafka.clients.NetworkClient.parseResponse( >> NetworkClient.java:380) >> >> at org.apache.kafka.clients.NetworkClient.handleCompletedReceives( >> NetworkClient.java:449) >> >> at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:269) >> >> at >> org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll( >> ConsumerNetworkClient.java:360) >> >> at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll( >> ConsumerNetworkClient.java:224) >> >> at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll( >> ConsumerNetworkClient.java:192) >> >> at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll( >> ConsumerNetworkClient.java:163) >> >> at >> org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady( >> AbstractCoordinator.java:179) >> >> at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce( >> KafkaConsumer.java:973) >> >> at org.apache.kafka.clients.consumer.KafkaConsumer.poll( >> KafkaConsumer.java:937) >> >> at org.apache.kafka.streams.processor.internals.StreamThread.runLoop( >> StreamThread.java:295) >> >> at org.apache.kafka.streams.processor.internals.StreamThread.run( >> StreamThread.java:218) >> >> >> I am running exactly the same code WordCountDemo from github. I downloaded >> all libraries, build with gradle for eclipse, imported them to eclipse and >> run from there. >> I initialized the zookeper and kafka-server and created kafka brooker as >> described in http://docs.confluent.io/3.0.0/streams/quickstart.html. >> >> I am using Eclipse Scala IDE 3.0 . >> >> >> Cheers >> Jeyhun >> -- >> -Cheers >> >> Jeyhun >
