使用Apache Kafka Java客户端(0.9),我正在尝试使用Kafka Producer类向代理发送一长串记录.
异步发送方法立即返回一段时间,然后在短时间内开始阻塞每次调用.大约三十秒后,客户端开始抛出异常(TimeoutException),并显示消息"Batch expired".
什么情况导致抛出此异常?
java apache-kafka message-hub ibm-cloud
apache-kafka ×1
ibm-cloud ×1
java ×1
message-hub ×1