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