THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
/**
* 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);
/**
* read byte array from input stream and then generate a producer record
* @return a producer record
*/
ProducerRecord<byte[], byte[]> readRecord();
/**
* Closes this reader
*/
default void close() {}
} |
...