Hi Buvana, com.fasterxml.jackson.core.JsonGenerator.setCurrentValue is introduced since Jackson 2.x but not in 1.x:
https://github.com/FasterXML/jackson-core/blob/master/src/main/java/com/fasterxml/jackson/core/JsonGenerator.java and Kafka Streams depend on version 2.6.3. It seems you bring in Jackson 1.x somehow, this may be helpful: http://stackoverflow.com/questions/31110506/jackson-error-no-such-method-com-fasterxml-jackson-core-jsongenerator-setcurre Guozhang On Tue, Apr 19, 2016 at 8:34 AM, Guillermo Lammers Corral < guillermo.lammers.cor...@tecsisa.com> wrote: > Hello, > > +1, same problem when I tried it. However, I dove into the code examples so > I can't give you a solution. > > 2016-04-19 17:20 GMT+02:00 Ramanan, Buvana (Nokia - US) < > buvana.rama...@nokia.com>: > > > 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) > > > > > -- -- Guozhang
