如何为 Kafka 提供通用的反序列化器
我正在进行从整体架构到微服务架构的迁移，因此我们计划使用Kafka作为代理。
我一直在我的项目中使用 kafka-client 依赖项 因此，对于每个主题，我都有不同的目的，并且将不同的对象传递给代理， 当执行此序列化时，对于生产者来说不是问题，但是当我想要使用时，我必须分别为每个对象编写一个反序列化器，我可以有一个通用的反序列化器吗？如果有的话有什么例子吗？
I am underway a migrational change from a monolithic to micro-services architecture, So we have planned to use Kafka as the broker.
I have been using the kafka-client dependency in my project
Therefore for every topic I have a different purpose and a different Object being passed onto the broker,
When doing this serialization isn't an issue on the producer front, but when I want to consume I am having to write a Deserializer for every Object separately, Can I have a generic Deserializer? If yes any examples?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
根据主题名称，您可以重定向到可以反序列化消息的所需方法。
例如，创建一个字典，其中键可以是主题名称，值可以是相应的反序列化器方法。
字典<字符串，动作> RegisteredDelegates = new Dictionary<字符串, Action>();
based on the topic name u can redirect to the required method which can deserialize the msg.
like, create a Dictionary in which the Key can be the topic name and the value will be the respective deserializer method.
Dictionary<string, Action> registeredDelegates = new Dictionary<string, Action>();