com.github.jcustenborder.kafka.connect.utils

Class SinkRecordHelper

java.lang.Object

com.github.jcustenborder.kafka.connect.utils.SinkRecordHelper

public class SinkRecordHelper
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static long	OFFSET
static int	PARTITION
static long	TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
SinkRecordHelper()

Method Summary

Modifier and Type	Method and Description
static org.apache.kafka.connect.sink.SinkRecord	delete(String topic, org.apache.kafka.connect.data.SchemaAndValue key)
static org.apache.kafka.connect.sink.SinkRecord	delete(String topic, org.apache.kafka.connect.data.Schema keySchema, Object key)
static org.apache.kafka.connect.sink.SinkRecord	delete(String topic, org.apache.kafka.connect.data.Struct key)
static org.apache.kafka.connect.sink.SinkRecord	write(String topic, org.apache.kafka.connect.data.SchemaAndValue key, org.apache.kafka.connect.data.SchemaAndValue value)
static org.apache.kafka.connect.sink.SinkRecord	write(String topic, org.apache.kafka.connect.data.Schema keySchema, Object key, org.apache.kafka.connect.data.Schema valueSchema, Object value)
static org.apache.kafka.connect.sink.SinkRecord	write(String topic, org.apache.kafka.connect.data.Struct key, org.apache.kafka.connect.data.Struct value)

Methods inherited from class java.lang.Object

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

Field Detail

PARTITION

public static final int PARTITION

See Also:

Constant Field Values

OFFSET

public static final long OFFSET

See Also:

Constant Field Values

TIMESTAMP

public static final long TIMESTAMP

See Also:

Constant Field Values

Constructor Detail

SinkRecordHelper

public SinkRecordHelper()

Method Detail

delete

public static org.apache.kafka.connect.sink.SinkRecord delete(String topic,
                                                              org.apache.kafka.connect.data.Struct key)

delete

public static org.apache.kafka.connect.sink.SinkRecord delete(String topic,
                                                              org.apache.kafka.connect.data.Schema keySchema,
                                                              Object key)

delete

public static org.apache.kafka.connect.sink.SinkRecord delete(String topic,
                                                              org.apache.kafka.connect.data.SchemaAndValue key)

write

public static org.apache.kafka.connect.sink.SinkRecord write(String topic,
                                                             org.apache.kafka.connect.data.Struct key,
                                                             org.apache.kafka.connect.data.Struct value)

write

public static org.apache.kafka.connect.sink.SinkRecord write(String topic,
                                                             org.apache.kafka.connect.data.Schema keySchema,
                                                             Object key,
                                                             org.apache.kafka.connect.data.Schema valueSchema,
                                                             Object value)

write

public static org.apache.kafka.connect.sink.SinkRecord write(String topic,
                                                             org.apache.kafka.connect.data.SchemaAndValue key,
                                                             org.apache.kafka.connect.data.SchemaAndValue value)