Kafka 基本操作

首先参考Kafka 安装步骤(Linux系统)启动相关服务

Kafka 提供了一个名为 kafka-topics.sh 的命令行实用程序，用于在服务器上创建主题

# 创建了一个名为 Hello-Kafka 的主题，其中包含一个分区和一个副本因子
# 创建主题后，可以在 Kafka 代理终端窗口中获取通知
# 并在/pwx/kafka-3.1.0/config/server.properties文件中“log.dirs=/tmp/kafka-logs/"
# 指定的目录下查看到主题日志文件"Hello-Kafka-0"
/pwx/kafka-3.1.0/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic Hello-Kafka

# 使用此命令查看当前存在的主题列表
/pwx/kafka-3.1.0/bin/kafka-topics.sh --list --bootstrap-server localhost:9092

# --broker-list 指定broker列表
# --topic 指定主题名称
/pwx/kafka-3.1.0/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic Hello-Kafka

创建完成后生产者将等待来自 stdin 的输入并发布到 Kafka 集群。 默认情况下，每个新行都作为新消息发布，然后在 config/producer.properties 文件中指定默认生产者属性。

# 与生产者类似，在config/consumer.proper-ties文件中指定了缺省使用者属性。 
# 打开一个新Linux终端输入以下命令
/pwx/kafka-3.1.0/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic Hello-Kafka --from-beginning

启动后在生产者终端输入内容后同时可以在消费者终端看到对应的内容

# 使用“alter”命令修改主题"Hello-kafka"分区计数
/pwx/kafka-3.1.0/bin/kafka-topics.sh --bootstrap-server localhost:9092 --alter --topic Hello-Kafka --partitions 2

# 删除主题主要大小写
/pwx/kafka-3.1.0/bin/kafka-topics.sh --bootstrap-server localhost:9092 --delete --topic Hello-Kafka