在我的 C# 代码中,我使用 Confluence Kafka 编写了一个消费者。我正在读取消息的时间戳,并希望将其转换为已知的时间和日期格式。我尝试了以下代码,但总是出现错误:System.FormatException:字符串'Confluence.Kafka.Timestamp'未被识别为有效的日期时间。我该如何解决这个问题?
public void Kafka_consumer()
{
//some code for getting message from Kafka topic
Kafka_TimeStamp_string = consumeResult.Message.Timestamp.ToString();
TimeStamp_dateTime = DateTime.ParseExact(Kafka_TimeStamp_string, "yyyy-MM-dd HH:mm:ss.fff", CultureInfo.InvariantCulture);
}
你可以只使用
Confluent.Kafka.Timestamp.UtcDateTime
:即使类型已经重载,也没有理由将其转换为字符串
ToString
(目前没有重载,因此您会得到返回类型名称的默认类型)。