第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號安全,請及時(shí)綁定郵箱和手機(jī)立即綁定
已解決430363個(gè)問題,去搜搜看,總會(huì)有你想問的

僅查看最后 5 分鐘數(shù)據(jù)的 Kafka 配置

僅查看最后 5 分鐘數(shù)據(jù)的 Kafka 配置

C#
阿波羅的戰(zhàn)車 2021-10-23 16:38:43
抱歉,我是 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ò)誤感謝您的幫助。
查看完整描述

1 回答

  • 1 回答
  • 0 關(guān)注
  • 125 瀏覽

添加回答

舉報(bào)

0/150
提交
取消
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號