THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
MessageReader adds close method to close some resources.
| 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
...