kafka-offsets

delete group

kafka-consumer-groups --bootstrap-server localhost:9092 --delete --group sender

reset kafka topic offset

JMX_PORT=5557 && kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group reach_extractor --reset-offsets --to-latest --topic message_responses --execute

set retention

kafka-topics --zookeeper cp-zookeeper:2181 --alter --topic message_spam_requests --config retention.ms=7200000

stop consuming

JMX_PORT=5557 && kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete-offsets --group worker --topic message_responses