Как сбросить смещение темы кафки?
Удалите consumer_offsets
- Остановите каждого брокера Kafka.
- Удалите весь каталог __consumer_offsets для каждого брокера (вы можете найти их в каталоге kafka-data)
- запустите kafka / bin / zookeeper-shell.sh {zookeeper_host: zookeeper_port} <<< "rmr / brokers / themes / __ consumer_offsets"
- Перезапустите брокеров.