抱歉,我是 Kafka 的新手,這個(gè)問題可能很簡單,但我需要一些幫助。我沒有弄清楚一些配置。有一個(gè)流數(shù)據(jù),我希望消費(fèi)者只能看到 procuders 發(fā)送的最后 5 分鐘的消息。我將 Confluent.Kafka 用于 .Net,var config = new Dictionary<string, object>{ {"group.id","Test1Costumers"}, {"bootstrap.servers",brokerEndpoint}, { "auto.commit.interval.ms", 60000}, { "auto.offset.reset", "earliest" } };這是 github 示例中消費(fèi)者的配置字典,另一個(gè)問題是我不想在主題中存儲超過 5 分鐘的消息,因?yàn)槿绻鼈兂^ 5 分鐘,我將不需要這些記錄。當(dāng)我配置 server.properties 時(shí);# The minimum age of a log file to be eligible for deletion due to agelog.retention.ms=60000一分鐘后,文件當(dāng)前使用的拋出錯(cuò)誤感謝您的幫助。
僅查看最后 5 分鐘數(shù)據(jù)的 Kafka 配置
阿波羅的戰(zhàn)車
2021-10-23 16:38:43