THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
kafka.common.MessageReader is a input argument of kafka-console-producer and we expect users can have their custom reader to produce custom records. Hence, MessageReader is a public interface and we should offer a java version to replace current scala code. Also, the new MessageReader should be placed at clients module. (kafka.common.MessageReader is in core module)
Public Interfaces
New org.apache.kafka.
...
clients.tool.RecordReader interface
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, 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() {} } |
...