Skip to content

Instantly share code, notes, and snippets.

@benpdavison

benpdavison/Remove meesages on kafka queue

Created September 3, 2018 08:59
Show Gist options
  • Save benpdavison/a4b52a7b2dcd397c6bf42a821d0f2129 to your computer and use it in GitHub Desktop.
Save benpdavison/a4b52a7b2dcd397c6bf42a821d0f2129 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Remove meesages on kafka queue
kafka-delete-records --bootstrap-server localhost:9092 --offset-json-file ./offsetfile.json
// where offsetfile.json is:
{"partitions": [{ "topic": "event_source.quotes", "partition": 0, "offset": -1 }], "version":1 }
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment