就是说我们需要 做 相应的配置 类如 props.put("serializer.class", "kafka.serializer.StringEncoder"); 然后consumer 做什么样的配置去反序列化呢,是不是这样
例如:
prop.put("key.deserializer", StringDeserializer.class.getName());
prop.put("value.deserializer", ByteArrayDeserializer.class.getName());
另外,可以到 org.apache.kafka.common.serialization.StringDeserializer 这个 package 下面看看kafka内置都支持哪些类型的序列化。