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

2017-05-03 Thread Matthias J. Sax
he queue, when the second instance came 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 >>

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

2017-05-03 Thread Matthias J. Sax
tition at the time of rebalance we see different > number of alerts. > > I have attached the log file for reference. > > Thanks, > Narendra > > > -Original Message----- > From: Andreas Voss > Sent: Tuesday, April 25, 2017 1:27 PM > To: users@kafka.apa

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

2017-05-03 Thread Andreas Voss
From: Andreas Voss Sent: Tuesday, April 25, 2017 1:27 PM To: users@kafka.apache.org Cc: Narendra Kumar ; Wladimir Schmidt ; Christian Leiner Subject: Re: Consumer with another group.id conflicts with streams() Hi Matthias, thank you for your response. Here are some more details: - my input a

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

2017-04-28 Thread Matthias J. Sax
gt; do that? > > Andreas > > > -Ursprüngliche Nachricht- > Von: Matthias J. Sax [mailto:matth...@confluent.io] > Gesendet: Montag, 24. April 2017 19:18 > An: users@kafka.apache.org > Betreff: Re: Consumer with another group.id conflicts with streams() > &g

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

2017-04-25 Thread Andreas Voss
users@kafka.apache.org Betreff: Re: Consumer with another group.id conflicts with streams() Hi, hard to diagnose. The new consumer should not affect the Streams app though -- even if I am wondering why you need it. > KafkaConsumer (with a UUID as group.id) that reads some historical > data

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

2017-04-24 Thread Matthias J. Sax
Hi, hard to diagnose. The new consumer should not affect the Streams app though -- even if I am wondering why you need it. > KafkaConsumer (with a UUID as group.id) that reads some historical data from > input topic Maybe using GlobalKTable instead might be a better solution? > (i.e. I feed 10

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