public class ConfluentMetricsFormatter extends Object implements org.apache.kafka.common.MessageFormatter
Constructor and Description |
---|
ConfluentMetricsFormatter() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
configure(Map<String,?> configs) |
void |
writeTo(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord,
PrintStream output) |
public void configure(Map<String,?> configs)
configure
in interface org.apache.kafka.common.Configurable
configure
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