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
