Kafka主题管理在Debian上的操作

在Debian上管理Kafka主题，通常涉及使用Kafka提供的命令行工具kafka-topics.sh。以下是一些基本操作及其说明：

创建主题

要创建一个新的Kafka主题，可以使用以下命令：

sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

• --create: 创建主题的指令。
• --zookeeper: 指定Kafka连接的Zookeeper服务地址。
• --replication-factor: 指定副本因子，即副本数量。
• --partitions: 指定分区个数。
• --topic: 指定要创建的主题名称。

查看主题列表

要列出所有Kafka主题，可以使用：

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

查看主题属性

要查看特定主题的详细信息，可以使用：

sh kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

修改主题配置

可以使用--alter选项来修改主题配置，例如更改分区数或副本因子：

sh kafka-topics.sh --alter --zookeeper localhost:2181 --topic my-topic --partitions 5

删除主题

要删除一个主题，可以使用：

sh kafka-topics.sh --delete --zookeeper localhost:2181 --topic test

发送和消费消息

• 发送消息到主题：

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

• 从主题消费消息：

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

请注意，上述命令中的localhost:2181和127.0.0.1:9092是示例，实际使用时需要根据您的Kafka集群配置进行相应的调整。此外，确保Kafka服务和Zookeeper服务正在运行，并且您有足够的权限执行这些操作。