Page History

/**
 * Typical implementations of this interface convert data from an `InputStream` received via `configure` into a
 * `ProducerRecord` instance on each invocation of `readRecord`. Noted that the implementations to have a public
 * nullary constructor.
 *
 * This is used by the `kafka.tools.ConsoleProducer`.
 */
public interface RecordReader extends Closeable {


    /**
     * Configures the RecordReader
     * @param inputStream of message
     * @param configs Map to configure the reader
     */
    void configure(InputStream inputStream, Map<String, ?> configs);
, Configurable {
    /**
     * read byte array from input stream and then generate a producer record
     * @param inputStream of message 
     * @return a producer record
     */
    ProducerRecord<byte[], byte[]> readRecord(InputStream inputStream);


    /**
     * Closes this reader
     */
    default void close() {}
}