对动态侦听器使用批处理模式

Question

我正在使用动态消息侦听器。一个例子如下所示。我想将其转换为批处理侦听器（一次使用多条消息）。

public class RetryMessageListener
    implements AcknowledgingConsumerAwareMessageListener<String, String> {

    @Override
    public void onMessage(ConsumerRecord<String, String> consumerRecord, Acknowledgement acknowledgement, Consumer<?, ?> consumer) {

    }

}

有没有办法转换这个，让监听器消费消费者记录列表？我正在使用 spring-kafka 和 spring-boot.

提前致谢

Answer 1

改为实施 BatchAcknowledgingConsumerAwareMessageListener。

/**
 * Listener for handling a batch of incoming Kafka messages, propagating an acknowledgment
 * handle that recipients can invoke when the message has been processed. The list is
 * created from the consumer records object returned by a poll. Access to the
 * {@link Consumer} is provided.
 *

对动态侦听器使用批处理模式

Use batch mode for dynamic listener

java

spring

apache-kafka

spring-boot

spring-kafka