kafka-cli.sh

# TOPICS

kafka-topics --bootstrap-server localhost:9092 --list

kafka-topics --bootstrap-server localhost:9092 --topic topic_name --create --partitions 3 --replication-factor 2 

kafka-topics --bootstrap-server localhost:9092 --topic topic_name --describe

kafka-topics --bootstrap-server localhost:9092 --topic topic_name --delete

# PRODUCER

kafka-console-producer --bootstrap-server localhost:9092 --topic topic_name

kafka-console-producer --bootstrap-server localhost:9092 --topic topic_name --producer-property acks=all

kafka-console-producer --bootstrap-server localhost:9092 --topic topic_name --producer-property parse.key=true --property key.seperator=:

# CONSUMER

kafka-console-consumer --bootstrap-server localhost:9092 --topic topic_name

kafka-console-consumer --bootstrap-server localhost:9092 --topic topic_name --from-beginning

kafka-console-consumer --bootstrap-server localhost:9092 --topic topic_name --formatter kafka.tools.DefaultMessageFormatter --property print.timestamp=true --property print.key=true --property print.value=true --from-beginning

# CONSUMER GROUP

kafka-consumer-groups --bootstrap-server localhost:9092 --list

kafka-consumer-groups --bootstrap-server localhost:9092 --describe --group group-name

kafka-consumer-groups --bootstrap-server localhost:9092 --group group-name --reset-offsets --to-earliest # no action

kafka-consumer-groups --bootstrap-server localhost:9092 --group group-name --reset-offsets --to-earliest --execute --all-topics

kafka-consumer-groups --bootstrap-server localhost:9092 --group group-name --reset-offsets --shift-by 2 --execute --all-topics

kafka-consumer-groups --bootstrap-server localhost:9092 --group group-name --reset-offsets --to-earliest --topic topic_name --execute