据我所知，Kafka没有这种机制；当然不是在springcloudstream或它所基于的库中。kafka客户机无法访问这种低级构造。
此外，消费者补偿完全独立于主题日志；在现代经纪商中，它们存储在一个特殊的主题中。
编辑
根据下面的评论 kafka-delete-records.sh 可以使用命令行工具。
注意，这使用scala AdminClient 默认情况下，它不在scst类路径上（从2.0开始）。
然而，java AdminClient 支持类似功能：

/**
 * Delete records whose offset is smaller than the given offset of the corresponding partition.
 *
 * This is a convenience method for {@link #deleteRecords(Map, DeleteRecordsOptions)} with default options.
 * See the overload for more details.
 *
 * This operation is supported by brokers with version 0.11.0.0 or higher.
 *
 * @param recordsToDelete       The topic partitions and related offsets from which records deletion starts.
 * @return                      The DeleteRecordsResult.
 */
public DeleteRecordsResult deleteRecords(Map<TopicPartition, RecordsToDelete> recordsToDelete) {
    return deleteRecords(recordsToDelete, new DeleteRecordsOptions());
}

您可以创建 AdminClient 使用 Boot
AutoConfiguration KafkaAdmin .

AdminClient client = AdminClient.create(kafkaAdmin.getConfig());