这是因为生产者会阻塞60秒(默认情况下)。
参见
max.block.msKafkadocumentation中的生产者配置。
max.block.ms配置控制了KafkaProducer.send()和KafkaProducer.partitionsFor()的阻塞时间,这些方法可以由于缓冲区已满或元数据不可用而被阻塞,用户提供的序列化器或分区器中的阻塞将不计入此超时时间。

这是因为生产者会阻塞60秒(默认情况下)。
参见
max.block.msKafkadocumentation中的生产者配置。
max.block.ms配置控制了KafkaProducer.send()和KafkaProducer.partitionsFor()的阻塞时间,这些方法可以由于缓冲区已满或元数据不可用而被阻塞,用户提供的序列化器或分区器中的阻塞将不计入此超时时间。