Re: [ANNOUNCE] New committer: Colin McCabe

2018-09-26 Thread Srinivas Reddy
Congratulations Colin 👏 - Srinivas - Typed on tiny keys. pls ignore typos.{mobile app} On Tue 25 Sep, 2018, 16:39 Ismael Juma, wrote: > Hi all, > > The PMC for Apache Kafka has invited Colin McCabe as a committer and we are > pleased to announce that he has accepted! > > Colin has contributed

Re: [ANNOUNCE] New Committer: Manikumar Reddy

2018-10-11 Thread Srinivas Reddy
Congratulations Mani. We'll deserved 👍 - Srinivas - Typed on tiny keys. pls ignore typos.{mobile app} On Fri 12 Oct, 2018, 01:39 Jason Gustafson, wrote: > Hi all, > > The PMC for Apache Kafka has invited Manikumar Reddy as a committer and we > are > pleased to announce that he has accepted! >

Re: [ANNOUNCE] New Committer: Vahid Hashemian

2019-01-15 Thread Srinivas Reddy
Congratulation Vahid!!! > On 16 Jan 2019, at 9:58 AM, Manikumar wrote: > > Congrats, Vahid! > > On Wed 16 Jan, 2019, 6:53 AM Ismael Juma >> Congratulations Vahid! >> >> On Tue, Jan 15, 2019, 2:45 PM Jason Gustafson > >>> Hi All, >>> >>> The PMC for Apache Kafka has invited Vahid Hashemian

Delete Specific Message from a Topic (partition)

2014-10-25 Thread Srinivas Reddy Kancharla
Hi, I have a scenario where I produce messages for a given topic (say having 10 partitions), and I have consumer group ( say mygroupID1) with 10 threads reading those 10 partitions. After consuming, I would like to delete specific messages from that topic (i.e. from a given partition). How shoul

Re: Delete Specific Message from a Topic (partition)

2014-10-26 Thread Srinivas Reddy Kancharla
tually consume only new > topic. > > Kind regards, > Stevo Slavic > On Oct 26, 2014 2:36 AM, "Srinivas Reddy Kancharla" > wrote: > > > Hi, > > > > I have a scenario where I produce messages for a given topic (say having > 10 > > parti

Consumer thread dies

2014-11-07 Thread Srinivas Reddy Kancharla
Hi, I have a scenario where I have 1 partition and 1 consumer group having 2 consumer threads running say C1 and C2. Since there is only one partition for a given topic, say C1 is holding that partition. Now due to some reason if C1 dies, can C2 get hold of that partition? i.e. C1 was busy with K

Re: Consumer thread dies

2014-11-09 Thread Srinivas Reddy Kancharla
mer thread. Please let me know if I am missing anything with "ConsumerConnector.createMessageStreams()". Thanks and regards, Srini On Fri, Nov 7, 2014 at 3:34 PM, Srinivas Reddy Kancharla wrote: > Hi, > > I have a scenario where I have 1 partition and 1 consumer group having

Re: Consumer thread dies

2014-11-10 Thread Srinivas Reddy Kancharla
> > Jun > > On Fri, Nov 7, 2014 at 3:34 PM, Srinivas Reddy Kancharla < > getre...@gmail.com > > wrote: > > > Hi, > > > > I have a scenario where I have 1 partition and 1 consumer group having 2 > > consumer threads running say C1 and C2. Since there