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 ...