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