所有操作位于/usr/local/kafka_2.12-3.5.1/bin。

root@ubuntu2203:/usr/local/kafka_2.12-3.5.1/bin# pwd
/usr/local/kafka_2.12-3.5.1/bin
root@ubuntu2203:/usr/local/kafka_2.12-3.5.1/bin# ls
connect-distributed.sh        kafka-delegation-tokens.sh  kafka-mirror-maker.sh               kafka-verifiable-consumer.sh
connect-mirror-maker.sh       kafka-delete-records.sh     kafka-producer-perf-test.sh         kafka-verifiable-producer.sh
connect-standalone.sh         kafka-dump-log.sh           kafka-reassign-partitions.sh        trogdor.sh
kafka-acls.sh                 kafka-e2e-latency.sh        kafka-replica-verification.sh       windows
kafka-broker-api-versions.sh  kafka-features.sh           kafka-run-class.sh                  zookeeper-security-migration.sh
kafka-cluster.sh              kafka-get-offsets.sh        kafka-server-start.sh               zookeeper-server-start.sh
kafka-configs.sh              kafka-jmx.sh                kafka-server-stop.sh                zookeeper-server-stop.sh
kafka-console-consumer.sh     kafka-leader-election.sh    kafka-storage.sh                    zookeeper-shell.sh
kafka-console-producer.sh     kafka-log-dirs.sh           kafka-streams-application-reset.sh
kafka-consumer-groups.sh      kafka-metadata-quorum.sh    kafka-topics.sh
kafka-consumer-perf-test.sh   kafka-metadata-shell.sh     kafka-transactions.sh

1、查看tocpic

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

2、创建一个topic

./kafka-topics.sh --bootstrap-server localhost:9092 --topic first --create --partitions 1

 3、查看主题详细信息

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

 4、修改topci分区数

只能增加，不能减少

./kafka-topics.sh --bootstrap-server localhost:9092 --topic first --alter --partitions 2

 5、生产者生产数据

/usr/local/kafka_2.12-3.5.1/bin# ./kafka-console-producer.sh --bootstrap-server localhost:9092 --topic first

 生产数据流程

 

 

 

6、消费者消费数据

--from-beginning：表示从头消费数据，按需添加

/usr/local/kafka_2.12-3.5.1/bin# ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic first --from-beginning