我正在使用springcloud@streamlistener订阅一个kafka主题。这个主题有大约100个分区。但根据我的要求,我只对0到20分区中的消息感兴趣。有没有办法配置springcloud来订阅这些分区,而不是订阅整个主题,这将不必要地用大量消息加载我的消费进程?使用kafka客户端库,这是可能的。但是springcloud提供了订阅主题分区的功能吗?任何有代码片段的人都将不胜感激。
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!