kafka consumer一次在.net core上使用许多消息,以减少对数据库的插入查询

cs7cruho  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(204)

我是Kafka的新手,我正在寻找一种方法,将许多消息作为一个批处理来使用,然后将它们一次插入数据库(因为我在做实时流服务,我不想连续多次写入数据库)。但是,在环顾了几天之后,看起来我一次只能消费和处理一条消息(似乎有一条消息) poll() 方法一次使用多条消息,但它已被删除(?)。有什么方法可以实现我在.NETCore上的目标吗?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题