Kafka自动将字符串数字字段转为整数问题及解决方法咨询

问题分析 #

这个问题本质是JSON序列化/反序列化组件的自动类型推断导致的：当组件检测到字符串内容是合法数字时，会自动将其转换为数值类型，尤其是当数字长度超过JavaScript安全整数范围（2^53-1，即9007199254740991）时，部分序列化器会优先转为整数类型处理。

解决方法 #

1. C#客户端配置（以Confluent.Kafka为例） #

方式一：使用强类型DTO

定义严格匹配消息结构的实体类，明确指定所有字段为字符串类型，序列化器会严格按字段类型处理，不会自动转换：

public class TestMessage
{
    public string test1 { get; set; }
    public string test2 { get; set; }
    public string test3 { get; set; }
    public string test4 { get; set; }
}

生产消息时直接序列化该实体类：

var producerConfig = new ProducerConfig { BootstrapServers = "你的Kafka Broker地址" };
using var producer = new ProducerBuilder<string, TestMessage>(producerConfig)
    .SetValueSerializer(new JsonSerializer<TestMessage>())
    .Build();

var message = new TestMessage
{
    test1 = "1",
    test2 = "9000000000000000",
    test3 = "9999999999999999",
    test4 = "10000000000000000"
};

await producer.ProduceAsync("你的主题名称", new Message<string, TestMessage> { Value = message });

方式二：自定义JSON序列化配置

如果使用动态对象（如JObject或匿名类），需配置JSON序列化器禁用自动类型转换（以Newtonsoft.Json为例）：

var serializerSettings = new JsonSerializerSettings
{
    // 禁止自动将字符串解析为数字
    FloatParseHandling = FloatParseHandling.None,
    // 严格保留原始类型
    TypeNameHandling = TypeNameHandling.None
};

var producer = new ProducerBuilder<string, object>(producerConfig)
    .SetValueSerializer(new JsonSerializer<object>(serializerSettings))
    .Build();

var messageObj = new
{
    test1 = "1",
    test2 = "9000000000000000",
    test3 = "9999999999999999",
    test4 = "10000000000000000"
};

await producer.ProduceAsync("你的主题名称", new Message<string, object> { Value = messageObj });

2. Confluent Web应用（Control Center） #

• 生产消息时：直接输入原始JSON字符串，确保数字字符串被双引号包裹，避免界面自动解析修改字段类型；
• 查看消息时：切换到Raw视图，这里会保留消息的原始字节和字符串格式，不会做类型转换。

核心原则 #

无论使用哪种工具，关键是让序列化器明确字段类型为字符串——要么通过强类型约束，要么通过序列化配置禁用自动类型推断，从源头阻止字符串到数字的转换。

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