Kafka Commands

kafka.properties

security.protocol=ssl
ssl.enabled.protocols = TLSv1.2,TLSv1.1,TLSv1
ssl.endpoint.identification.algorithm=

kafka_windows_commands

# Start Zookeeper Server
zookeeper-server-start.bat config/zookeeper.properties

# Start Kafka Server
kafka-server-start.bat config/server.properties

# Topic Operations
kafka-topics.sh --list --bootstrap-server 127.0.0.1:9092 --command-config kafka.properties
kafka-topics.sh --zookeeper localhost:2181 --topic <topic_name> --create --partitions <partition_count> --replication-factor <replication_factor_size> --config retention.ms=<retention_period>
kafka-topics.sh --zookeeper localhost:2181 --topic <topic_name> --delete

# Produce To Topic
kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic <topic_name>
kafka-console-producer.bat --broker-list 127.0.0.1:9092 --topic <topic_name> --producer-property acks=all

# Consume From Topic
kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic <topic_name> --from-beginning
kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic <topic_name> --from-beginning --group <group_name>

# Consumer Groups
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --list
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group <group_name>
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --describe --group <group_name> --state
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group <group_name> --reset-offsets --to-earliest --execute --all-topics
kafka-consumer-groups.bat --bootstrap-server localhost:9092 --group <group_name> --topic<topic_name> --reset-offsets --to-earliest --command-config kafka.properties --execute
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --command-config kafka.properties --delete --group <group_name>