java - 我怎样才能有一个通用的 Kafka 反序列化器

Question

我正在进行从架构monolithic到micro-services架构的迁移更改，因此我们计划Kafka用作代理。

我一直在我的项目中使用kafka-client依赖项因此对于每个主题我都有不同的目的和不同的对象被传递给代理，当做这个序列化在生产者面前不是问题，但是当我想要消耗我必须为每个对象分别编写一个反序列化器，我可以有一个通用的Deserializer吗？如果是的话，有什么例子吗？

Answer 1

根据主题名称，您可以重定向到可以反序列化消息的所需方法。比如，创建一个字典，其中的键可以是主题名称，值将是相应的反序列化方法。Dictionary<string, Action> registeredDelegates = new Dictionary<string, Action>();