Kafka 中的 Topic 就像是消息的存储区,管理起来挺简单,但细节上还是需要注意。要创建一个 Topic,可以通过命令行工具kafka-topics.sh
来操作。比如,创建一个名为myTopic
的 Topic,带 3 个分区和 1 个副本,可以直接用这个命令:
bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 3 --topic myTopic
除了创建,查看现有的 Topic 也简单,直接用--list
参数:
bin/kafka-topics.sh --list --bootstrap-server localhost:9092
说到分区,它对 Kafka 的性能提升挺有,分区数多了,能力就更强。但要注意,删除 Topic 时一定要小心,因为一旦删除就无法恢复,使用--delete
就可以删除 Topic。
对于企业环境,如果你要管理安全性,也能通过命令行工具加一些安全参数,像--security-protocol
之类的。不过,整体来说,Kafka 的 Topic 管理操作并不复杂,学会了这些基本命令,优化 Kafka 集群就容易多。