Check out the kafka-consumer-groups command line tool. You can set the current offsets for any inactive consumer group to whatever value you like using that tool. I think that'll do what you want.
On Thu, Nov 15, 2018 at 12:17 PM Parth Gandhi < parth.gan...@excellenceinfonet.com> wrote: > Hi Team, > > We have implemented kafka and would like to know if there is a way to > remove kafka message stuck in a Queue and commit offset using the kafka > command line. Or has it to be done using the consumer API. > > Thanks, > Parth Gandhi > DevOps > > Disclaimer > > The information contained in this communication from the sender is > confidential. It is intended solely for use by the recipient and others > authorized to receive it. If you are not the recipient, you are hereby > notified that any disclosure, copying, distribution or taking action in > relation of the contents of this information is strictly prohibited and may > be unlawful. > > This email has been scanned for viruses and malware, and may have been > automatically archived by Mimecast Ltd, an innovator in Software as a > Service (SaaS) for business. Providing a safer and more useful place for > your human generated data. Specializing in; Security, archiving and > compliance. To find out more visit the Mimecast website. >
