我们随机NetworkExceptions而且TimeoutExceptions在我们的生产环境中:
Brokers: 3
Zookeepers: 3
Servers: 3
Kafka: 0.10.0.1
Zookeeeper: 3.4.3
Run Code Online (Sandbox Code Playgroud)
我们偶尔会在生产者日志中获得此异常:
超过TOPIC的10条记录:XXXXXX:自创建批次以及延迟时间后已经过了5608 ms.
此类错误消息中的毫秒数不断变化.有时它的〜5秒其他时间长达~13秒!
我们很少得到:
NetworkException: Server disconnected before response received.
Run Code Online (Sandbox Code Playgroud)
集群由3名 经纪人和3名 动物园管理员组成.生产者服务器和Kafka集群在同一网络中.
我正在进行同步通话.有一个Web服务,多个用户请求调用它来发送数据.Kafka Web服务有一个Producer对象,它执行所有发送.生产者的请求超时最初为1000毫秒,已更改为15000毫秒(15秒).即使在增加超时期限后TimeoutExceptions仍会出现错误日志.
可能是什么原因?