com.northconcepts.datapipeline.kafka

Class RecordSerializer

java.lang.Object

com.northconcepts.datapipeline.kafka.RecordSerializer

public class RecordSerializer
extends Object

Constructor Summary

Constructors

Constructor and Description
RecordSerializer()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordSerializer

public RecordSerializer()

Method Detail

close

public void close()

configure

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

serialize

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