public class TierMessageFormatter
extends java.lang.Object
implements kafka.common.MessageFormatter
Constructor and Description |
---|
TierMessageFormatter() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
init(java.util.Properties props) |
void |
writeTo(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord,
java.io.PrintStream output) |
public void init(java.util.Properties props)
init
in interface kafka.common.MessageFormatter
public void writeTo(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord, java.io.PrintStream output)
writeTo
in interface kafka.common.MessageFormatter
public void close()
close
in interface kafka.common.MessageFormatter