com.northconcepts.datapipeline.kafka

Class RecordDeserializer

java.lang.Object

com.northconcepts.datapipeline.kafka.RecordDeserializer

public class RecordDeserializer
extends Object

Constructor Summary

Constructors

Constructor and Description
RecordDeserializer()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> configs, boolean isKey)
Record	deserialize(String topic, byte[] record)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecordDeserializer

public RecordDeserializer()

Method Detail

close

public void close()

configure

public void configure(Map<String,?> configs,
                      boolean isKey)

deserialize

public Record deserialize(String topic,
                          byte[] record)