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 `init``configure` into a * `ProducerRecord` instance on each invocation of `readRecord`. * * 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() {} } |
...