kafka寫入流程，二、kafka基本操作和管理

列出所有主題

kafka-topics.bat --zookeeper localhost:2181 --list

列出所有主題的詳細信息

kafka-topics.bat --zookeeper localhost:2181 --describe

創建主題 主題名 my-topic，1 副本，8 分區

kafka-topics.bat --zookeeper localhost:2181 --create --topic my-topic --replication-factor 1 --partitions 8

增加分區，注意：分區無法被刪除

kafka-topics.bat --zookeeper localhost:2181 --alter --topic my-topic --partitions 16

創建生產者（控制臺）

kafka寫入流程。kafka-console-producer.bat --broker-list localhost:9092 --topic my-topic

創建消費者（控制臺）

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic my-topic --from-beginning

列出消費者群組（僅 Linux）

kafka-topics.sh --new-consumer --bootstrap-server localhost:9092 --list

列出消費者群組詳細信息（僅 Linux）

kafka-topics.sh --new-consumer --bootstrap-server localhost:9092 --describe --group 群組名