例如：prop.put("key.deserializer", StringDeserializer.class.getName());prop.put("value.deserializer", ByteArrayDeserializer.class.getName());另外，可以到 org.apache.kafka.common.serialization.StringDeserializer 这个 package 下面看看kafka内置都支持哪些类型的序列化。
就是说我们需要 做 相应的配置 类如 props.put("serializer.class", "kafka.serializer.StringEncoder"); 然后consumer 做什么样的配置去反序列化呢，是不是这样
用什么加密，就实现相应的解密
基本都支持，需要自己实现相应的序列化方式。
找不到想要的答案？提一个您自己的问题。
0 声望
这家伙太懒，什么都没留下
例如：
prop.put("key.deserializer", StringDeserializer.class.getName());
prop.put("value.deserializer", ByteArrayDeserializer.class.getName());
另外，可以到 org.apache.kafka.common.serialization.StringDeserializer 这个 package 下面看看kafka内置都支持哪些类型的序列化。
就是说我们需要 做 相应的配置 类如 props.put("serializer.class", "kafka.serializer.StringEncoder"); 然后consumer 做什么样的配置去反序列化呢，是不是这样
用什么加密，就实现相应的解密
基本都支持，需要自己实现相应的序列化方式。
你的答案