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 集群就容易多。