我有一个java应用程序，它将twitter数据流化并发送到kafka主题。它们最终被Spark流处理。目前，我刚刚 String 物体。如果我想送 String [] 阵列？如何设置序列化/反序列化？谢谢你的帮助。
String
String []
5kgi1eie1#
您可以实现一个定制的序列化程序/反序列化程序，其中第一个元素应该是数组中的元素数（编码为整数），然后是数组中每个编码为字符串长度（整数）的字符串，最后是组成字符串的字节。
1条答案
按热度按时间5kgi1eie1#
您可以实现一个定制的序列化程序/反序列化程序，其中第一个元素应该是数组中的元素数（编码为整数），然后是数组中每个编码为字符串长度（整数）的字符串，最后是组成字符串的字节。