Package org.apache.kafka.tools.api

package org.apache.kafka.tools.api
Provides interfaces for writing plugins of kafka tools
  • Class
    Description
    Decoder<T>
    A decoder is a method of turning byte arrays into objects.
    DefaultDecoder
    The default implementation does nothing, just returns the same byte array it takes in.
    IntegerDecoder
    The integer decoder translates bytes into integers.
    LongDecoder
    The long decoder translates bytes into longs.
    RecordReader
    Typical implementations of this interface convert data from an `InputStream` received via `readRecords` into a iterator of `ProducerRecord` instance.
    StringDecoder
    The string decoder translates bytes into strings.