Kafka流:POJO序列化/反序列化

我们可以使用Kafka Streams中的哪个类/方法将Java对象序列化/反序列化为字节数组,反之亦然?以下链接建议使用ByteArrayOutputStream&ObjectOutputStream,但它们不是线程安全的。

Send Custom Java Objects to Kafka Topic

还有另一个使用ObjectMapper的选项,ObjectReader(用于线程安全),但它是从POJO转换而来的->JSON->拜蒂雷。看来这是一个广泛的选择。希望检查是否有一种直接的方法可以将对象转换为bytearray,反之亦然,这是线程安全的。请建议

import org.apache.kafka.common.serialization.Serializer;
public class HouseSerializer<T> implements Serializer<T>{
    private Class<T> tClass;
    public HouseSerializer(){

    }

    @SuppressWarnings("unchecked")
    @Override
    public void configure(Map configs, boolean isKey) {
        tClass = (Class<T>) configs.get("POJOClass");       
    }

    @Override
    public void close() {
    }

    @Override
    public byte[] serialize(String topic, T data) {
        //Object serialization to be performed here
        return null;
    }
}

注:卡夫卡版本-0.10.1