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

Class KeyPlainWriter

java.lang.Object

io.aiven.kafka.connect.common.output.plainwriter.KeyPlainWriter

All Implemented Interfaces:

OutputFieldPlainWriter

public final class KeyPlainWriter
extends Object
implements OutputFieldPlainWriter

Constructor Summary

Constructors

Constructor	Description
KeyPlainWriter()

Method Summary

Modifier and Type	Method	Description
void	write(org.apache.kafka.connect.sink.SinkRecord record, OutputStream outputStream)	Takes the SinkRecord's key as a byte array.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KeyPlainWriter

public KeyPlainWriter()

Method Details

write

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

Takes the SinkRecord's key as a byte array.

If the key is null, it outputs nothing.

If the key is not null, it assumes the key is a byte array.

Specified by:

write in interface OutputFieldPlainWriter

Parameters:

record - the record to get the key from

outputStream - the stream to write to

Throws:

org.apache.kafka.connect.errors.DataException - when the key is not actually a byte array

IOException