阅读量:295
在Debian上管理Kafka主题，通常涉及使用Kafka提供的命令行工具kafka-topics.sh。以下是一些基本操作及其说明：
创建主题
要创建一个新的Kafka主题，可以使用以下命令：
sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看主题列表
要列出所有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服务正在运行，并且您有足够的权限执行这些操作。