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
...