基于nuclio的Kafka触发的服务在接收序列化消息时将如何行为

bxgwgixi  于 2023-11-16  发布在  Apache
关注(0)|答案(1)|浏览(137)

我正在写一个基于nuclio的服务,它是由Kafka触发的。根据我的理解,每当一个消息被生成到服务订阅的主题时,处理函数将接收消息,并且可以使用事件对象访问它们。
如果消息是avro/protobuf序列化的,处理程序函数接收的消息是否已经被序列化,或者我是否必须编写自定义代码来序列化这些消息?
我是相当新的nuclio为基础的服务,所以原谅我的知识不足,并请觉得纠正我的理解,如果错误的。

8ftvxx2r

8ftvxx2r1#

Kafka数据总是序列化的。因此必须进行序列化,并且任何Kafka消费者都必须设置序列化设置。您使用的任何框架都应该记录如何配置消费者。
如果您仅限于字节/字符串转换,那么是的,您将配置字节或以其他方式获取base64字符串,例如,然后需要在处理程序中使用自己的解码/转换函数(使用内置的Kafka转换器或外部转换器,例如来自Confluent的转换器
https://github.com/nuclio/nuclio/issues/916

相关问题