在我的应用程序中,为了不使用@kafkalistener注解,我创建了自己的自定义侦听器。我配置为在一个记录到另一个记录基中侦听消息。这是有效的。现在我想将我的自定义侦听器转换为批量侦听消息。我是否应该将consumerconfig.max\u poll\u records\u config配置为每次轮询要处理的消息量?我也会把ackmode改为batch。我只需要这么做吗?
我知道concurrentkafkalistenercontainerfactory具有属性“setbatchlistener(true)”,但就我所了解的kafka文档而言,这种工厂配置仅与@kafkalistener注解一起使用。
任何帮助都将不胜感激。
1条答案
按热度按时间bvhaajcl1#
只需将侦听器更改为实现
BatchMessageListener
或者它的一个子接口。容器将自动检测其类型。请参阅消息侦听器。
这个
@KafkaListener
代码使用工厂标志来确定要创建哪种类型的侦听器适配器。