当前位置: 首页 > news >正文

kafka生产者指定ip

kafka生产者指定ip

最近工作中遇到一个问题,记录一下,需求中要求往kafka上推送信息。本来是个很简单的需求,但是踩了一个坑。

​ 我通过spring boot集成了kafka写了一个生产者,客户那边给我三个节点的ip,然后我也没多想就配置上来了,但是实际上客户的集群中搞了10个主机部署了kafka,然后我就无了。我只配置了给我的三个节点的hosts,后端就开始疯狂报错hosts unknow的异常。

spring:kafka:bootstrap-servers: ip1:9092,ip2:9092,ip3:9092

​ 这里需要讲一下kafka的机制,当你使用Kafka生产者发送消息时,Kafka会根据负载均衡策略在所有可用的Kafka节点之间进行分配,以确保负载均衡和容错。所以,我的生产者可能会向配置的主机以外的主机发送消息。

​ 如果要限制消息发送到特定的主机, 可以使用spring.kafka.producer.bootstrap-servers属性来指定要使用的Kafka节点的主机地址,而不是使用spring.kafka.bootstrap-servers属性。

spring:kafka:producer:bootstrap-servers: ip1:9092,ip2:9092,ip3:9092
http://www.lryc.cn/news/109536.html

相关文章:

  • python 封装sql 增删改查连接MySQL
  • Flink正常消费一段时间后,大量反压,看着像卡住了,但又没有报错。
  • 软件测试需求分析的常用方法
  • 数据结构10 -查找_树表查找
  • 第126天:内网安全-隧道技术SSHDNSICMPSMB上线通讯LinuxMac
  • 开发一个饲料商城小程序需要多少钱
  • Emacs之set-face-attribute与font-lock-add-keywords用法区别(一百二十八)
  • JavaScript高阶函数和闭包
  • 私有化部署企业IM即时通讯:提升效率、防止泄密、高效协同办公
  • react ant icon的简单使用
  • 用Rust实现23种设计模式之原型模式
  • visual studio 2022 编译时出现MSB3721问题
  • Android 获取网络连接状态新方法
  • 可缝合神经网络
  • Android优化篇|网络预连接
  • pyspark使用XGboost训练模型实例
  • 完整模型的训练套路
  • PtahDAO:全球首个DAO治理资产信托计划的金融平台
  • 从零搭建一个react + electron项目
  • MATLAB /Simulink 快速开发STM32(使用st官方工具 STM32-MAT/TARGET),以及开发过程
  • LeetCode 热题 100 JavaScript--102. 二叉树的层序遍历
  • 常见Git命令
  • 在C语言中调用汇编语言的函数
  • Delphi Professional Crack,IDE插件开发和扩展IDE
  • 程序框架-公共MONO模块
  • 采用鲁棒随机森林实现的流异常检测:Python应用的一种新型机器学习方法
  • 缓存友好在实际编程中的重要性
  • uni-ajax网络请求库使用
  • MYSQL进阶-事务
  • python 常见数据类型和方法