AW: Consumer with another group.id conflicts with streams()

2017-05-03 Thread Andreas Voss
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

Re: Consumer with another group.id conflicts with streams()

2017-04-25 Thread Andreas Voss
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,

Consumer with another group.id conflicts with streams()

2017-04-24 Thread Andreas Voss
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