Kafka生产者与消费者配置详解

59 阅读 0 评论 39 点赞

我是靠谱客的博主等待玉米，最近开发中收集的这篇文章主要介绍Kafka生产者与消费者配置详解，觉得挺不错的，现在分享给大家，希望可以做个参考。

kafka消费：

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

注：--bootstrap-server表示要消费的集群和队列。--topic test表示消费话题为test。–from-beginning参数表示从最开始消费数据，旧的和新的数据都会被消费，而没有该参数表示只会消费新产生的数据

kafka生产：

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

注：--broker-list表示生产的内容保存在哪个集群。--topic test表示生产的话题为test

低版本消费不是--bootstrap-server hostname而是--zookeeper hostname，我的是高版本因此用--bootstrap-server。

生产和消费的hostname要与config目录下的server.properties配置文件中的 listeners=PLAINTEXT://192.168.174.131:9092填写一致，否则报错：

配置使用时，注意区分高低版本，有很多使用区别，避免走坑。

以上就是等待玉米为你收集整理的Kafka生产者与消费者配置详解的全部内容，希望文章能够帮你解决Kafka生产者与消费者配置详解所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。