使用kafka 0.9将消息保存在主题/分区中多长时间

Hug*_*ona 5 java apache-kafka

我正在使用kafkaConsumer api从主题获取数据(每个主题一个分区),在通过poll方法检索所有记录并进行处理后,如果创建了新的kafkaConsumer实例并尝试从同一主题/分区获取数据然后我就能像第一次那样检索相同的数据.有没有办法在消费后从主题/分区中删除记录?