Hug*_*ona 5 java apache-kafka
我正在使用kafkaConsumer api从主题获取数据(每个主题一个分区),在通过poll方法检索所有记录并进行处理后,如果创建了新的kafkaConsumer实例并尝试从同一主题/分区获取数据然后我就能像第一次那样检索相同的数据.有没有办法在消费后从主题/分区中删除记录?
归档时间:
9 年,10 月 前
查看次数:
1099 次
最近记录: