主题命令行操作

在 Kafka 的安装目录下输入命令：bin/kafka-topics.sh，可以查看操作主题的命令的参数。

参数 描述
—bootstrap-server 连接的 Kafka Broker 主机名称和端口号
—topic 操作的 topic 名称
—create 创建主题
—delete 删除主题
—alter 修改主题
—list 查看所有主题
—describe 查看主题详细描述
—partitions 设置分区数
—replication-factor 设置分区副本
—config 更新系统默认的配置

查看 Kafka 服务器中的所有 topicbin/kafka-topics.sh --bootstrap-server localhost:9092 --list

创建 topic：bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --partitions 1 --replication-factor 1 --topic first（topic 的名称为 first，分区数 1，分区副本数 1）

修改 topic 的分区数：bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic first --partitions 2（分区数只能增加，不能减少）

删除 topic：bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic first

查看 topic 的详情：bin/kafka-topics.sh --bootstrap-server localhost:9092 --describe --topic first
image.png
image.png

生产者命令行操作

参数 描述
—bootstrap-server 连接的 Kafka Broker 主机名称和端口号
—topic 操作的 topic 名称

发送消息：bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic myFirstTopic

消费者命令行操作

参数 描述
—bootstrap-server 连接的 Kafka Broker 主机名称和端口号
—topic 操作的 topic 名称
—from-beginning 从头开始消费
—group 指定消费者组名称

消费某个 topic 中的数据：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic myFirstTopic

退出生产者、消费者客户端：Ctrl + C

把 topic 中所有的数据都读取出来：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic myFirstTopic（包括历史数据）