首页 > 解决方案 > 无法使用 Confluent.Kafka.Serialization。我应该安装任何其他 nuget 库吗?

问题描述

我正在关注 youtube 上关于使用 C# 为 Kafka 创建消费者应用程序的指南,但在使用部分,我无法使用 Confluent.Kafka.Serialization。缺少序列化。

关于我应该包含/使用什么才能使用 StringDeserializer 的任何想法?

标签: c#apache-kafkaconfluent-platformserialization

解决方案


我相信您正在遵循的教程使用过时的旧 Confluent.Kafka 库。

如果要设置反序列化器,可以使用接受IDeserializer接口的SetValueDeserializerSetKeyDeserializer方法。您可以实现自己的反序列化器,它可以在内部使用 StringDeserializer。

您还可以查看另一个提供简单 IDeserializer 实现的答案。


推荐阅读