在Debian上操作Kafka主题管理,你可以使用Kafka自带的命令行工具kafka-topics.sh
。以下是一些基本操作步骤:
要创建一个名为 “test-topic” 的Topic,2个分区,1个副本,可以在终端中执行以下命令:
kafka-topics.sh --create --bootstrap-server localhost:9092 --topic test-topic --partitions 2 --replication-factor 1
启动生产者控制台,向 “test-topic” 发送消息:
kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test-topic
在控制台中输入消息后按回车键发送。
从最新消息开始消费 “test-topic”:
kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --from-beginning
要查看Topic的详细信息,可以使用以下命令:
kafka-topics.sh --describe --bootstrap-server localhost:9092 --topic test-topic
kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group my-group --describe
kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic test-topic
请注意,执行这些命令通常需要具有相应的权限。如果需要,可以使用sudo
来提升权限。
此外,如果你需要更高级的管理功能,可以考虑使用第三方工具,如Kafka Manager或Kafka Tool,这些工具提供了更友好的图形界面来管理Kafka集群。