Kafka Producer 错误：'未指定值序列化程序，并且没有为类型定义默认序列化程序......'

Question

我刚开始使用Kafka，遇到以下菜鸟错误：

'Value cannot be null.
Parameter name: Value serializer not specified and there is no default serializer defined for type ActMessage.'

尝试发送类对象 ActMessage 对象而不是示例附带的简单字符串时会发生这种情况。引发错误的代码行是：

using (var p = new ProducerBuilder<Null, ActMessage>(config ).Build()

我正在使用.net client.

我的理解是，我需要在第一个类型参数中使用一个默认序列化，即 Kafka 客户端附带的一个，如 here 所述，但在此 .net 包中找不到它们。 我想我可以建造一个，但那将是浪费时间。

这是一个可重现的例子：

public class ActMessage  {
    public int SomeId {get;set;}
    public string SomeContent {get;set;}
}

class Tester  {

void send(){

    var config = new ProducerConfig { BootstrapServers = "localhost:9092" };

        using (var p = new ProducerBuilder<Null, ActMessage>(config).Build()) //throws error here
        {
            var dr = p.ProduceAsync("news", new Message<Null, ActMessage>
            {
                Value = new ActMessage { SomeId = 1, SomeContent="hi" },
            }
                ).Result;
        }
    }
}

Answer 1

我建议查看该 repo 中的工作 examples/ 目录，以查看可以复制到自己项目中的工作代码。

---

如果你有自己的类，你需要实现ISerializer和IDeserializer接口。

或者您可以使用built-in ones

---

但是，use Avro 的替代方法是

这需要编写一个Avro schema file，然后使用avrogen 来创建你的类，而不是手动编写它。例如

dotnet tool install --global Apache.Avro.Tools

avrogen -s User.avsc .

那么你必须always add some ValueSerializer in Kafka clients才能发送数据