Class AbstractJsonOutputStreamWriter
java.lang.Object
io.aiven.kafka.connect.common.output.jsonwriter.AbstractJsonOutputStreamWriter
- All Implemented Interfaces:
OutputStreamWriter
- Direct Known Subclasses:
JsonLinesOutputStreamWriter
-
Method Summary
Modifier and TypeMethodDescriptionvoidwriteOneRecord(OutputStream outputStream, org.apache.kafka.connect.sink.SinkRecord record) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface io.aiven.kafka.connect.common.output.OutputStreamWriter
startWriting, stopWriting, writeRecordsSeparator
-
Method Details
-
writeOneRecord
public void writeOneRecord(OutputStream outputStream, org.apache.kafka.connect.sink.SinkRecord record) throws IOException - Specified by:
writeOneRecordin interfaceOutputStreamWriter- Throws:
IOException
-