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 shoul

Re: Example of using simple consumer to fetch from multiple partitions of a topic

Thanks will take a look. On Friday, October 24, 2014, Neha Narkhede wrote: > Is there a better way to do this where I can build one big requests with > broker -> partition mappings and call a consumer.fetch() with one giant > request? > > Unfortunately, not until the 0.9 consumer is released. Un