原文:java代码向kafka集群发送消息报org.apache.kafka.common.errors.TimeoutException: Batch Expired

由于项目是springboot项目,在application.properties加入 logging.level.root debug debug日志报错信息为kafka集群ip别名访问失败 在windows上配置ip别名 C: Windows System drivers etc hosts ...

2019-12-16 16:08 0 1014 推荐指数:

查看详情

kafka2.11-0.9.0.0实现Producer发送消息时,无法发送,报错信息:org.apache.kafka.common.errors.TimeoutException: Batch Expired

最开始在本机搭建了kafka集群,本地 producer 客户端成功发布消息至 broker。随后在服务器(虚拟机)上搭建了 kafka 集群,在本机连接该集群,producer 却无法发布消息到 broker(奇怪也没有抛错)。最开始怀疑是 iptables 没开放,于是开放端口,结果还不 ...

Thu Mar 19 22:47:00 CST 2020 0 1092
kafka producer batch 发送消息

Sender 类实现了 Runnable 接口,封装了具体的逻辑,发送消息和接收响应都在这个类中。 3. 执行回调 ...

Sun Jan 06 20:38:00 CST 2019 0 851
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM