我一直在使用 Kafka .NET 客戶端，一切正常，但現在時間戳是自動設定的，我需要的是能夠發送我自己的時間戳。
var kp = new kafkaDatapoint
{
value = p.Value,
tags = p.tags
};
await _producer.ProduceAsync(p.Variable, new Message<string, kafkaDatapoint>()
{
Key = p.Variable,
Value = kp
});
這是我用來發送資料的代碼。如何覆寫時間戳？
我正在使用這個包https://docs.confluent.io/clients-confluent-kafka-dotnet
uj5u.com熱心網友回復：
Message 類還有一個 Timestamp 欄位
https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/Confluent.Kafka/MessageMetadata.cs#L30
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/348158.html
標籤：。网 阿帕奇卡夫卡 confluent-kafka-dotnet