kafka-offset-reset

Simple cli tool to reset offsets in Kafka using node-rdkafka

Usage no npm install needed!

<script type="module">
  import kafkaOffsetReset from 'https://cdn.skypack.dev/kafka-offset-reset';
</script>

README

Overview

Simple, straightforward tool to reset kafka offsets with librdkafka. Use at your own risk.

Installing

npm install -g kafka-offset-reset

CLI options

kafka-offset-reset --brokers <brokerstring> --topic <topic> --group <group> --partition <partition> --offset <new-offset> [--dry-run] -- [librdkafka args]

Example

kafka-offset-reset --brokers localhost:9093 --topic test --group test --partition 0 --offset 200000 --dry-run -- ssl.key.location=uat.key ssl.certificate.location=uat.key ssl.ca.location=ca.crt security.protocol=ssl