我们可以根据应用的需要在 Kafka 里创建一些 Topic 分别存储不同类型的数据。用 kafka-topics 命令可以管理 Kafka 里的 Topic。
执行一下 kafka-topics.sh 先用一个 --bootstrap-server 设置一下 Kafka 服务器,之前我们已经在本地电脑上启动过一个 Kafka 服务,服务的默认的端口号是 9092。
创建一个 Topic 可以使用 --create 选项,再加上一个 --topic 选项,后面是要创建的 Topic 的名字,比如 demo 。执行一下,会显示 Created topic demo ,创建了一个叫 demo 的 Topic。
列出 Kafka 里的所有的 Topic 可以使用 kafka-topics.sh 命令,这里可以用一个 --list 选项,会显示在 Kafka 里面,现在有了一个叫 demo 的 Topic。
要查看这个 Topic 的详细信息,可以使用 kafka-topics 命令,加上 describe 这个选项,再用 --topic 设置一下要查看的 Topic 的名字。这里会显示这个 Topic 的名字,还有它的分区的数量,备份的数量这些东西。
再创建一个 Topic,名字是 message ,然后查看 Kafka 里的 Topic 的列表,这里会多出一个 message。 要删除 Topic 可以执行 kafka-topics 命令,后面用一个 delete 选项,然后在 topic 选项的后面,设置一下要删除掉的 Topic 的名字,比如我们把 demo 删除掉。
然后再查看 Topic 列表,现在我的 Kafka 里面就只有一个 message 这个 Topic。