Apache Kafka Commands : cheat list

Hi folks, hereby is handy kafka commands.
Kafka installation directory : /apps/kafka/live/
server Ip : use DNS or use IP ( my server ) or use localhost or localhost ip (
zookeeper port : 2181 (default port)
broker port : 9092 (default port)

1.) Start

zookeeper :

bin/zookeeper-server-start.sh   config/zookeeper.properties

kafka broker :

in/kafka-server-start.sh config/server.properties 

Kafka connect debezium :

bin/connect-standalone.sh config/connect-standalone.properties  config/connect-file-source.properties

2.) List & Create & describe & Alter & Delete Topics

List All Topics

bin/kafka-topics.sh --zookeeper --list

List Topics which are altered configuration (different from default)

bin/kafka-topics.sh --zookeeper localhost:2181 --describe --topics-with-overrides

Create Topic : **replication factor <= number of broker

bin/kafka-topics.sh  --zookeeper --topic first_topic --create --partitions 2 --replication-factor 2

Create Topic with compression algorithm & retention time :

bin/kafka-topics.sh  --zookeeper localhost:2181 --topic first_topic --create --partitions 6  --config compression.type=gzip --config retention.ms=86400000 --replication-factor 2 

Create Topic with Acknowledge property

bin/kafka-console-producer.sh  --broker-list 1localhost:9092  --topic first_topic --producer-property acks=all

Describe Topic:

bin/kafka-topics.sh --zookeeper localhost:2181 --topic first_topic --describe

Alter retention time:

bin/kafka-configs.sh --zookeeper --entity-type topics --entity-name ng-fss-files --alter --add-config retention.ms=7200000

Latest offset

bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list, --topic ng-fss-files-staging --time -1   

Last offset

 bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list, --topic ng-fss-files-staging --time -2

Flush all messages from topic : assuming 2 partition.
** altering the retention time to 1 ms & reverting back to previous retention time once flushed should also work as per other blogs (no luck with me)
step 1.) create json file . eg:

  "partitions": [
      "topic": "first_topic",
      "partition": 0,
      "offset": -1
      "topic": "first_topic",
      "partition": 1,
      "offset": -1
  "version": 1

step2.) execute the json file

bin/kafka-delete-records.sh --bootstrap-server --offset-json-file purge_first_topic_config_flush.json 

3.) Produce / Consume

Produce :

bin/kafka-console-producer.sh  --broker-list  --topic first_topic

consumer :

bin/kafka-console-consumer.sh --bootstrap-server --topic first_topic

consume from beginning : **order is maintained at partition level, reading from beginning in topic not ensure order

bin/kafka-console-consumer.sh --bootstrap-server --topic first_topic --from-beginning

consumer group:

bin/kafka-console-consumer.sh --bootstrap-server --topic first_topic --group first-topic-consumer

0 0 votes
Article Rating
Notify of
1 Comment
Newest Most Voted
Inline Feedbacks
View all comments
2 years ago

[…] Apache Kafka Commands : cheat list […]


Enjoy this blog? Please spread the word :)

Would love your thoughts, please comment.x