Hello,
I went thru QuickStart instructions at:
http://docs.confluent.io/2.1.0-alpha1/streams/quickstart.html
Downloaded confluent-2.1.0-alpha1, started ZK & kafka servers. Continuously
producing to topic : streams-file-input.
However, running the WordCountJob example throws error (pasting the message
below).
java version "1.7.0_79"
OpenJDK Runtime Environment (IcedTea 2.5.5) (7u79-2.5.5-0ubuntu0.14.04.2)
OpenJDK 64-Bit Server VM (build 24.79-b02, mixed mode)
Please help resolve the issue.
thanks,
Buvana
~/confluent-2.1.0-alpha1$ ./bin/kafka-run-class
org.apache.kafka.streams.examples.wordcount.WordCountJob
[2016-04-19 11:09:14,223] WARN The configuration zookeeper.connect =
localhost:2181 was supplied but isn't a known config.
(org.apache.kafka.clients.producer.ProducerConfig)
[2016-04-19 11:09:14,344] WARN The configuration num.standby.replicas = 0 was
supplied but isn't a known config.
(org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-19 11:09:14,344] WARN The configuration zookeeper.connect =
localhost:2181 was supplied but isn't a known config.
(org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-19 11:09:14,344] WARN The configuration __stream.thread.instance__ =
Thread[StreamThread-1,5,main] was supplied but isn't a known config.
(org.apache.kafka.clients.consumer.ConsumerConfig)
[2016-04-19 11:09:14,350] WARN The configuration zookeeper.connect =
localhost:2181 was supplied but isn't a known config.
(org.apache.kafka.clients.consumer.ConsumerConfig)
Exception in thread "StreamThread-1" java.lang.NoSuchMethodError:
com.fasterxml.jackson.core.JsonGenerator.setCurrentValue(Ljava/lang/Object;)V
at
com.fasterxml.jackson.databind.ser.std.MapSerializer.serialize(MapSerializer.java:445)
at
com.fasterxml.jackson.databind.ser.std.MapSerializer.serialize(MapSerializer.java:29)
at
com.fasterxml.jackson.databind.ser.DefaultSerializerProvider.serializeValue(DefaultSerializerProvider.java:129)
at
com.fasterxml.jackson.databind.ObjectMapper._configAndWriteValue(ObjectMapper.java:3387)
at
com.fasterxml.jackson.databind.ObjectMapper.writeValueAsString(ObjectMapper.java:2781)
at
org.apache.kafka.streams.processor.internals.InternalTopicManager.createTopic(InternalTopicManager.java:178)
at
org.apache.kafka.streams.processor.internals.InternalTopicManager.makeReady(InternalTopicManager.java:89)
at
org.apache.kafka.streams.processor.internals.StreamPartitionAssignor.assign(StreamPartitionAssignor.java:362)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.performAssignment(ConsumerCoordinator.java:227)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader(AbstractCoordinator.java:393)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.access$700(AbstractCoordinator.java:81)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:343)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:324)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:665)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:644)
at
org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:167)
at
org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:133)
at
org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:107)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.onComplete(ConsumerNetworkClient.java:380)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:274)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:213)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:193)
at
org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:163)
at
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:222)
at
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.ensurePartitionAssignment(ConsumerCoordinator.java:311)
at
org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:890)
at
org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:853)
at
org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:325)
at
org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:248)
