如果先前的消息处理被阻止,则用 Spring 注释的方法 Kafka 侦听器不会接收消息
Method annotated with Spring Kafka listener is not receiving message if previous message processing is blocked
在我的项目中,我使用 Spring Kafka 侦听器来使用来自 Kafka 的消息。我怀疑,如果 consume 方法代码由于某种原因被阻塞并且再也没有返回,在这种情况下,这个监听器是否能够接收到新消息并继续进行,或者它会被挂起?在我的例子中,看起来,Kafka 监听器也被阻塞了,没有处理进一步的消息,甚至,同一组的另一个消费者也没有收到消息。
否;当线程被阻塞时,您不会获得更多记录,除非并发性 > 1 并且至少有那么多分区。即使那样,您也不会再收到分配给被阻止的消费者的分区的消息。
在我的项目中,我使用 Spring Kafka 侦听器来使用来自 Kafka 的消息。我怀疑,如果 consume 方法代码由于某种原因被阻塞并且再也没有返回,在这种情况下,这个监听器是否能够接收到新消息并继续进行,或者它会被挂起?在我的例子中,看起来,Kafka 监听器也被阻塞了,没有处理进一步的消息,甚至,同一组的另一个消费者也没有收到消息。
否;当线程被阻塞时,您不会获得更多记录,除非并发性 > 1 并且至少有那么多分区。即使那样,您也不会再收到分配给被阻止的消费者的分区的消息。