kafka生产/消费消息

本文转自：https://blog.csdn.net/weixin_36691991/article/details/108832523

Kafka自带一个命令行客户端，它从文件或标准输入中获取输入，并将其作为message（消息）发送到Kafka集群。默认情况下，每行将作为单独的message发送。

运行 producer，然后在控制台输入一些消息以发送到服务器。

1

2

3

> ./kafka-console-producer.sh --broker-list localhost:9092 --topic test

This is a message

This is another message

 启动一个 consumer

Kafka 还有一个命令行consumer（消费者），将消息转储到标准输出。

1

2

3

> ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

This is a message

This is another message

如果您将上述命令在不同的终端中运行，那么现在就可以将消息输入到生产者终端中，并将它们在消费终端中显示出来。

所有的命令行工具都有其他选项；运行不带任何参数的命令将显示更加详细的使用信息。

————————————————

版权声明：本文为CSDN博主「壹小俊」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。

原文链接：https://blog.csdn.net/weixin_36691991/article/details/108832523