我正在编写一个基于 nuclio 的服务,该服务由 kafka 触发。根据我的理解,每当向服务订阅的主题生成消息时,处理函数都会接收该消息,并且可以使用事件对象来访问它们。
如果消息是 avro/protobuf 序列化的,处理函数收到的消息是否已经被反序列化,或者我是否必须编写自定义代码来反序列化这些消息?
我对基于 nuclio 的服务相当陌生,所以请原谅我缺乏知识,如果我的理解有误,请纠正我的理解。
我正在编写一个基于 nuclio 的服务,该服务由 kafka 触发。根据我的理解,每当向服务订阅的主题生成消息时,处理函数都会接收该消息,并且可以使用事件对象来访问它们。
如果消息是 avro/protobuf 序列化的,处理函数收到的消息是否已经被反序列化,或者我是否必须编写自定义代码来反序列化这些消息?
我对基于 nuclio 的服务相当陌生,所以请原谅我缺乏知识,如果我的理解有误,请纠正我的理解。
Kafka 数据始终是序列化的。因此必须进行反序列化,并且任何 Kafka 消费者都必须设置反序列化器设置。您使用的任何框架都应该记录如何配置消费者。
如果您仅限于字节/字符串反序列化,那么是的,您可以配置字节或以其他方式获取 Base64 字符串,例如,然后需要使用您自己的解码/反序列化函数(使用内置 Kafka 反序列化器或外部反序列化器,例如来自 Confluence)在处理程序中
https://github.com/nuclio/nuclio/issues/916