Re: Consumer thread dies

C1 hung? Thanks, 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 is only one partition for a given topic, say

Re: Consumer thread dies

. 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 getre...@gmail.com wrote: Hi, I have a scenario where I have 1 partition and 1 consumer group having 2 consumer

Re: Delete Specific Message from a Topic (partition)

regards, Stevo Slavic On Oct 26, 2014 2:36 AM, Srinivas Reddy Kancharla getre...@gmail.com wrote: 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

Delete Specific Message from a Topic (partition)

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