有沒有辦法分解消息，以便只使用最新的消息？我試圖將消息保存在列表中，但沒有成功var consumer = new Consumer(new ConsumerOptions(topic, router));foreach (var message in consumer.Consume()){ Console.WriteLine(Encoding.UTF8.GetString(message.Value));}輸出應(yīng)為：1、2、3、4輸出為：1、1、2、1、2、3、1、2、3、4
2 回答
鴻蒙傳說
TA貢獻(xiàn)1865條經(jīng)驗(yàn) 獲得超7個(gè)贊
事實(shí)上，做你想做的唯一方法是有一個(gè)單一分區(qū)的主題并將max.poll.records設(shè)置為一個(gè)。
否則，就沒有辦法了，因?yàn)樽詈笠粭l消息沒有意義。任何輸入消息都可以被推送到不同的分區(qū)中，并且您有一些與主題所具有的分區(qū)數(shù)相關(guān)的最后消息。
- 2 回答
- 0 關(guān)注
- 247 瀏覽
添加回答
舉報(bào)
0/150
提交
取消