Spring Kafka listenerExecutor

作者: ℘ 宋唐 ℒº ѵ ℯ楚厦
发布时间: 2025-03-03 06:52:26 (2天前)
转自：

2 条回复

0#
回复此人
咿呀哟 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 如果您的主题只有一个分区，则根据使用者组策略，只有一个使用者能够轮询该分区。 </p> <P> 该 <code> ConcurrentMessageListenerContainer </code> 确实创造了同样多的目标 <code> KafkaMessageListenerContainer </code> 提供的实例 <code> concurrency </code> 。并且仅在它不知道主题中的分区数量的情况下才这样做。 </p> <P> 当消费者组中的重新平衡发生时，只有一个消费者获得消费分区。所有工作都是在一个线程中完成的： </p> <pre> <code> private void startInvoker() { ListenerConsumer.this.invoker = new ListenerInvoker(); ListenerConsumer.this.listenerInvokerFuture = this.containerProperties.getListenerTaskExecutor() .submit(ListenerConsumer.this.invoker); } </code> </pre> <P> 一个分区 - 一个用于顺序记录处理的线程。 </p> </DIV>

编辑

登录后才能参与评论