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
