我们可以把数据放到不同的 Topic 里面。 确定 Confluent 平台的服务已经启动了,在控制中心,打开在我们自己电脑上运行的这个集群,然后打开 Topics,这里会显示集群里所有的 Topics。 我们可以直接在这个控制中心创建新的 Topic,或者也可以在命令行使用命令创建新的 Topic。
在终端,可以执行一下 kafka-topic 这个命令,注意 Confluent 里带的 Kafka 命令行工具没有后缀。后面加上 --bootstrap-server 设置一下 Kafka 服务器,这里就是 localhost:9092,再用 --create 选项,创建一个--topic,名字是 demo ,执行一下。
在控制中心的 Topics 这里会显示刚才我们在命令行创建的这个 demo。 在命令行,可以执行 kafka-topics 命令,用一个 --list 选项,这样可以列出所有的 Topic,这里会有刚才我们创建的这个 demo。