misha_cafex v0.0.6 Mix.Tasks.Cafex.OffsetReset

Reset consumer group’s offsets. You should really carful in using this task.

Examples

mix cafex.offset_reset -t topic -g group -b localhost:9092 -s strategy

Command line options

  • -t, --topic - Topic name
  • -g, --group - Consumer group name
  • -b, --broker - The Kafka broker in the form: host1:port1
  • -s, --strategy - Reset to the latest of earliest