THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
The current implementation scheme is not complicated, it does not have much difference with Line MessageReader, but in order to distinguish it from Line, I extracted FileMessageReader.
MessageReader
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
trait MessageReader {
def init(inputStream: InputStream, props: Properties): Unit = {}
def readMessage(): ProducerRecord[Array[Byte], Array[Byte]]
def close(): Unit = {}
} |
FileMessageReader
...
| language | scala |
|---|---|
| title | FileMessageReader |
...
FileMessageReader will be used to detect the availability of the input file list and read multiple files.
Compatibility, Deprecation, and Migration Plan
...