Бережливая сериализация и десериализация в Kafka Streaming

Question

Я использую Thrift только для выполнения сериализации и десериализации для повышения производительности при потоковой передаче байтовых данных из kafka

. Когда я десериализую, я получаю эту ошибку:

org.apache.thrift.protocol.TProtocolException: Нераспознанный тип 123

Мой код

public void streamMessageByte() {   
    final StreamsBuilder builder = new StreamsBuilder();
    <Integer, byte[]> stream = builder.stream(kafka_topic);
    deserializer = new TDeserializer();
    serializer = new TSerializer();
    //Thrift class pojo object is 'deser' which matches byte array data format
    stream.map((k,v){

        try{
            deserializer.deserialize(deser, v);
        }

        catch(TException e){

        }
    null;
});