.NET DateTime转Kafka Timestamp与Date类型的实现方法

一、对应Java fromLogical方法的完整C#实现 #

Kafka Connect的Date类型要求传入的日期必须是UTC时区的午夜时间（时分秒、毫秒均为0），转换逻辑是将日期转为Unix纪元（1970-01-01 UTC）以来的天数，以int类型存储。对应Java方法的C#实现如下：

// 和Java端保持一致的每日毫秒数常量
private const long MILLIS_PER_DAY = 86400000;

public int? KafkaConnectDateFromLogical(DateTime? date)
{
    if (!date.HasValue)
        return null;

    // 转换为UTC时间，确保时区统一
    var utcDate = date.Value.ToUniversalTime();

    // 校验时间部分是否符合Kafka Connect Date的约束
    if (utcDate.Hour != 0 || utcDate.Minute != 0 || utcDate.Second != 0 || utcDate.Millisecond != 0)
        throw new ArgumentException("Kafka Connect Date类型不允许包含非零的时分秒或毫秒值");

    // 计算Unix纪元到目标日期的毫秒数
    var unixEpoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
    long unixMillis = (long)(utcDate - unixEpoch).TotalMilliseconds;

    // 转换为天数并返回
    return (int)(unixMillis / MILLIS_PER_DAY);
}

二、自定义EncodedDate方法的验证 #

你提供的EncodedDate方法核心转换逻辑是正确的，但缺少Java方法中关键的时间部分校验和潜在的时区处理问题：

1. 缺少校验逻辑：Java方法会对日期的时分秒、毫秒是否全为0做校验，不符合则抛出异常；你的方法会直接计算天数，可能导致不符合Kafka Connect的Schema约束。
2. 时区风险：若DateTimeToUnixTimestampMs方法未基于UTC时间计算，会因本地时区偏差导致转换结果错误。

要让EncodedDate完全等效于Java的fromLogical，需要补充时区转换和校验逻辑，修改后的版本如下：

private const long MILLIS_PER_DAY = 86400000;

// 确保Unix毫秒数计算基于UTC
private long DateTimeToUnixTimestampMs(DateTime? date)
{
    var utcDate = date.Value.ToUniversalTime();
    var unixEpoch = new DateTime(1970, 1, 1, 0, 0, 0, DateTimeKind.Utc);
    return (long)(utcDate - unixEpoch).TotalMilliseconds;
}

public int? EncodedDate(DateTime? date)
{
    if (!date.HasValue)
    {
        return null;
    }

    var utcDate = date.Value.ToUniversalTime();
    // 补充Kafka Connect Date的时间部分校验
    if (utcDate.Hour != 0 || utcDate.Minute != 0 || utcDate.Second != 0 || utcDate.Millisecond != 0)
        throw new ArgumentException("Kafka Connect Date类型不允许包含非零的时分秒或毫秒值");

    var unixMillis = DateTimeToUnixTimestampMs(date);
    return (int)(unixMillis / MILLIS_PER_DAY);
}

内容的提问来源于stack exchange，提问作者chsakell