kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Apurva Mehta <apu...@confluent.io>
Subject Re: Suggestions
Date Fri, 02 Dec 2016 19:50:35 GMT
>
>  then, the strange thing is that the consumer on
> the second topic which stay in poll forever, *without receive any message*.


How long is 'forever'? Did you wait more than 5 minutes?

On Fri, Dec 2, 2016 at 2:55 AM, Vincenzo D'Amore <v.damore@gmail.com> wrote:

> Hi Kafka Gurus :)
>
> I'm creating process between few applications.
>
> First application create a producer and then write a message into a main
> topic (A), within the message there is the name of a second topic (B). Then
> promptly create a second producer and write few message into the new topic
> (B).
>
> I write here because I don't understand why, a second application which is
> in poll on the main topic, when receive the first message (which contain
> the name of second topic), then, the strange thing is that the consumer on
> the second topic which stay in poll forever, *without receive any message*.
>
> What is wrong in this scenario, am I missing something? Please help.
>
> producer has this default properties:
>
>       "bootstrap.servers":"localhost:9092",
>       "acks":"all",
>       "retries":0,
>       "batch.size":16384,
>       "linger.ms":1,
>       "buffer.memory":33554432,
>
> "key.serializer":"org.apache.kafka.common.serialization.StringSerializer",
>
> "value.serializer":"org.apache.kafka.common.serialization.
> StringSerializer"
>
> consumer has this default properties:
>
>       "bootstrap.servers":"localhost:9092",
>       "enable.auto.commit":"true",
>       "auto.commit.interval.ms":"1000",
>       "session.timeout.ms":"30000",
>       "buffer.memory":33554432,
>       "key.deserializer":
> "org.apache.kafka.common.serialization.StringDeserializer",
>       "value.deserializer":
> "org.apache.kafka.common.serialization.StringDeserializer"
>
> usually there are 2 active groups (group_A and group_B).
>
> Best regards,
> Vincenzo
>
> --
> Vincenzo D'Amore
> email: v.damore@gmail.com
> skype: free.dev
> mobile: +39 349 8513251
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message