对不起，我是Kafka的新人，这个问题可能很简单，但我需要一些帮助。我没有弄清楚一些配置。有一个数据流，我希望消费者看到只有最后5分钟的消息，procuders发送。我正在使用confluent.kafka for.net，

var config = new Dictionary<string, object>{
                {"group.id","Test1Costumers"},
                {"bootstrap.servers",brokerEndpoint},
                { "auto.commit.interval.ms", 60000},
                { "auto.offset.reset", "earliest" }
            };

下面是github中消费者的配置字典示例，另一个问题是我不想在一个主题中存储超过5分钟的消息，因为如果它们超过5分钟，我就不需要这些记录。
当我配置server.properties时；

# The minimum age of a log file to be eligible for deletion due to age

log.retention.ms=60000

一分钟后，文件当前使用的抛出错误
谢谢你的帮助。