我们在系统中使用kafka进行流处理。输入数据\消息的结构非常复杂。那么如何定义输入消息的结构。这是最适合输入数据\消息的结构和序列化机制。
bq3bfh9z1#
您可以使用下面的序列化程序来序列化输入消息。apache commons lang3序列化程序-最简单的实现kryo序列化-快速高效的序列化程序avro序列化-支持随着时间的推移使用注册表进行模式演化我建议你使用kryo Seralizer。
1条答案
按热度按时间bq3bfh9z1#
您可以使用下面的序列化程序来序列化输入消息。
apache commons lang3序列化程序-最简单的实现
kryo序列化-快速高效的序列化程序
avro序列化-支持随着时间的推移使用注册表进行模式演化
我建议你使用kryo Seralizer。