Package io.aiven.kafka.connect.common.output

Interface OutputStreamWriter

All Known Implementing Classes:

AbstractJsonOutputStreamWriter, JsonLinesOutputStreamWriter

public interface OutputStreamWriter

Method Summary

Modifier and Type	Method	Description
default void	startWriting(OutputStream outputStream)
default void	stopWriting(OutputStream outputStream)
void	writeOneRecord(OutputStream outputStream, org.apache.kafka.connect.sink.SinkRecord record)
default void	writeRecordsSeparator(OutputStream outputStream)

Method Details

startWriting

default void startWriting(OutputStream outputStream)
                   throws IOException

Throws:

IOException

writeRecordsSeparator

default void writeRecordsSeparator(OutputStream outputStream)
                            throws IOException

Throws:

IOException

writeOneRecord

void writeOneRecord(OutputStream outputStream,
 org.apache.kafka.connect.sink.SinkRecord record)
             throws IOException

Throws:

IOException

stopWriting

default void stopWriting(OutputStream outputStream)
                  throws IOException

Throws:

IOException