Khởi động Zookeeper

bin/zkServer.sh start

Hoặc sử dụng script có sẵn của Kafka:

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

Khởi động Kafka broker

bin/kafka-server-start.sh -daemon config/server.properties

Dừng Kafka broker (cần đợi vài giây để hoàn tất tiến trình dọn dẹp)

bin/kafka-server-stop.sh config/server.properties

Tạo Topic mới

Lưu ý: Với Kafka phiên bản mới, tham số --zookeeper không còn được hỗ trợ; thay vào đó dùng --bootstrap-server.

Ví dụ tạo topic với 1 partition và 1 bản sao:

./kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --partitions 1 --replication-factor 1 --create --topic topicName

Xóa Topic

./kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --delete --topic topicName

Khởi động Producer (console)

./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic topicName

Khởi động Consumer (console)

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic topicName

Thêm --from-beginning nếu muốn đọc lại tất cả dữ liệu từ đầu:

./kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic topicName --from-beginning

Liệt kê danh sách Topics

./kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --list

Đếm số lượng message (offset nhỏ nhất)

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic TOPIC_NAME --time -2

Đếm số lượng message (offset lớn nhất)

./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic TOPIC_NAME --time -1

Xem thông tin offset của một nhóm consumer

./kafka-consumer-groups.sh --describe --group groupName --bootstrap-server 127.0.0.1:9092

Thiết lập offset thủ công cho một nhóm và topic

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group groupName --topic topicName --execute --reset-offsets --to-offset 10000

Thiết lập offset về giá trị nhỏ nhất (đầu tiên)

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group GROUP_NAME --reset-offsets --execute --to-earliest --topic TOPIC_NAME

Thiết lập offset về giá trị lớn nhất (mới nhất)

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group GROUP_NAME --reset-offsets --execute --to-latest --topic TOPIC_NAME

Liệt kê danh sách các nhóm consumer

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list

Xem chi tiết topic (bao gồm số partition)

./kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic TopicName

Thay đổi số partition của topic

./kafka-topics.sh --alter --bootstrap-server localhost:9092 --topic TopicName --partitions SỐ_PARTITION_MỚI

Xem trạng thái tiêu thụ của một nhóm

./kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group group_name --describe