Today, when a batch is expired in the accumulator, a TimeoutException is raised to the user. It might be better the producer to retry the expired ...

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

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

问题反馈： xx现场测试环境下，整个平台的数据，除了原始数据模块，其他模块正常运行。相同版本的包，在线上环境上原始数据的订阅是正常的，但是测试环境没有，查看所有相关的日志，均没有报异常，且日志中有正常显示已经把数据发送到kafka。但是从kafka的日志里查，没有收到转发过来的数据 ...

收到某业务组的小伙伴发来的反馈，具体问题如下： 项目中某 kafka 消息组消费特别慢，有时候在 kafka-manager 控制台看到有些消费者已被踢出消费组。 从服务端日志看到如下信息： 该消费组在短时间内重平衡了 600 多次。 从 cat 查看得知，每条消息处理都会有 4 次数 ...

问题描述： 在消费端能够正常消费到Kafka数据并成功生产到producer topic 中，当将kafka的一台机器关机之后，正常情况下应该是 消费端是不受影响的。因为有还有两台的负载机器。问题就是一台机器停止运行之后，消费端酒 shutdown 而无 ...

CPU 利用率高的排查方法 看看该机器的连接数是不是比其他机器多,监听的端口数：netstat -anlp | wc -l Kafka-0.8的停止和启动 启动: cd /usr/local/kafka-0.8.0-release/ && nohup ./bin ...

Request idle timed out at 123000 ms. That means there was no activity (read or write) for 123000 ms ...