用户登录

把数据放到 Kafka 里的东西就是 Producer,也就是数据的生产者。下面我们可以通过命令,往 Kafka 里放几条数据。执行一下 kafka-console-producer.sh 后面用 --bootstrap-server 设置一下 Kafka 服务的地址,这里就是 localhost:9092 ,然后用 --topic 选项,设置一下要把数据放到哪个 Topic 里面,我们之前创建过一个 message ,可以往这个 Topic 里面添加一条数据,比如 hello 。

Consumer,是数据的使用者,或者叫消费者。Consumer 可以使用生产者生产出来的数据,新建一个终端标签,执行一下 kafka-console-consumer.sh 用 --bootstrap-server 设置一下 Kafka 服务的地址 localhost:9092,然后再用 --topic 设置一下要使用哪个 Topic 里的数据,可以设置成 message。

如果想让这个 Consumer 使用 Producer 之前生产出来的数据,可以再加上一个 --from-beginning 这个选项。你会发现这里输出了一个 hello 。

回到这个 Producer 窗口,再输入一条信息, hello ninghao.net , 你会看到在 Consumer 窗口输出了 Producer 生产出来的这条数据。

数据生产者(Producer)与消费者(Consumer)《 Kafka:起步 》

统计

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

社会化网络

关于

微信订阅号

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