用户登录

往 Kafka 的 Topic 里发信息的东西叫 Producer,就是信息的生产者。一般 Producer 就是你自己写的一些服务端应用。在控制中心,打开之前我们创建的这个 Topic, 然后打开 Messages, 这个 Topic 里如果有新的信息就会在这里显示出来。下面我们可以使用 Kafka 提供的命令行工具,往这个 Topic 里放点数据。

在终端,执行一下 kafka-console-producer ,--bootstrap-server 是 localhost:9092,连接到 Kafka 服务,--topic 是 demo ,执行一下。输入一条信息,按下回车。

在控制中心这里会直接显示这个 Topic 里的新的信息。我们可以观察一下这条信息, 这条信息所属的 Topic 就是 demo,这条信息存储在了编号是 1 的这个分区里了。

信息的 offset 就是这条信息在当前这个分区里的一个 id 号,默认这个 id 号是从 0 开始的,也就是这个分区里的第一个信息的 offset 是 0,第二条信息的 offset 就会是 1 。

timestamp 是这条信息的生产时间,timestampType 是 CREATE_TIME ,信息的 headers,也就是信息的头部数据,这条信息没有带 headers。 后面还有一个 key ,是这个信息的名字,生产这条信息的时候没有特别设置这个 key,所以这条信息的 key 就会是 null,信息的 value 是这条信息的具体的值,这里就是 你好。

Messages:消息《 Kafka:关键概念 》

统计

14696
分钟
0
你学会了
0%
完成

社会化网络

关于

微信订阅号

扫描微信二维码关注宁皓网,每天进步一点