up. Looks like the second
instance tries to initiate a rebalance that fails.
Thanks,
Andreas
-Ursprüngliche Nachricht-
Von: Narendra Kumar
Gesendet: Mittwoch, 3. Mai 2017 13:11
An: Andreas Voss ; users@kafka.apache.org
Cc: Wladimir Schmidt ; Christian Leiner
Betreff: RE: Consumer with
ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG,
> Integer.toString(Integer.MAX_VALUE)); <- increase to infinity
> from default of 300 s
We will change the default values accordingly in future release but for now you
should set this manually.
Hope this helps.
-Matthias
On 4/24/17 10:01 AM,
Hi, I have a simple streaming app that copies data from one topic to another,
so when I feed 1000 records into source topic I receive 1000 records in the
target topic. Also the app contains a transform() step which does nothing,
except instantiating a KafkaConsumer (with a UUID as group.id) that