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