You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Guillermo Lammers Corral <gu...@tecsisa.com> on 2016/04/19 17:34:30 UTC
Re: Kafka Streams - preview version - Exception in thread "StreamThread-1"
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.ramanan@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)
>
>
Re: Kafka Streams - preview version - Exception in thread "StreamThread-1"
Posted by Guozhang Wang <wa...@gmail.com>.
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.corral@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.ramanan@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