Kafka .NET 客户端自定义时间戳

Question

我一直在使用 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

Answer 1

消息 class 也有时间戳字段

https://github.com/confluentinc/confluent-kafka-dotnet/blob/master/src/Confluent.Kafka/MessageMetadata.cs#L30