Package org.apache.kafka.common

Interface MessageFormatter

All Superinterfaces:
AutoCloseable, Closeable, Configurable
public interface MessageFormatter extends Configurable, Closeable
This interface allows to define Formatters that can be used to parse and format records read by a Consumer instance for display. The kafka-console-consumer has built-in support for MessageFormatter, via the --formatter flag. Kafka provides a few implementations to display records of internal topics such as __consumer_offsets, __transaction_state and the MirrorMaker2 topics.

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    close()
    Closes the formatter
    default void
    configure(Map<String,?> configs)
    Configures the MessageFormatter
    void
    writeTo(ConsumerRecord<byte[],byte[]> consumerRecord, PrintStream output)
    Parses and formats a record for display

  • Method Details

    • configure

      default void configure(Map<String,?> configs)
      Configures the MessageFormatter
      Specified by:
      configure in interface Configurable
      Parameters:
      configs - Map to configure the formatter

    • writeTo

      void writeTo(ConsumerRecord<byte[],byte[]> consumerRecord, PrintStream output)
      Parses and formats a record for display
      Parameters:
      consumerRecord - the record to format
      output - the print stream used to output the record

    • close

      default void close()
      Closes the formatter
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable