java—使kafka concurrentmessagelistenercontainer批量工作

gijlo24d  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(709)

在我的应用程序中,为了不使用@kafkalistener注解,我创建了自己的自定义侦听器。我配置为在一个记录到另一个记录基中侦听消息。这是有效的。现在我想将我的自定义侦听器转换为批量侦听消息。我是否应该将consumerconfig.max\u poll\u records\u config配置为每次轮询要处理的消息量?我也会把ackmode改为batch。我只需要这么做吗?
我知道concurrentkafkalistenercontainerfactory具有属性“setbatchlistener(true)”,但就我所了解的kafka文档而言,这种工厂配置仅与@kafkalistener注解一起使用。
任何帮助都将不胜感激。

bvhaajcl

bvhaajcl1#

只需将侦听器更改为实现 BatchMessageListener 或者它的一个子接口。容器将自动检测其类型。
请参阅消息侦听器。
这个 @KafkaListener 代码使用工厂标志来确定要创建哪种类型的侦听器适配器。

相关问题