Package io.aiven.kafka.connect.common.source.task

Class Context<K extends Comparable<K>>

java.lang.Object

io.aiven.kafka.connect.common.source.task.Context<K>

Type Parameters:

K - is is the type/class of the key unique to the object the context is being created about

public class Context<K extends Comparable<K>>
extends Object

A Context which captures all the details about the source which are required to successfully send a source record onto Kafka

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Context(Context<K> anotherContext)	Creates a defensive copy of the Context
	Context(K storageKey)

Method Summary

Modifier and Type	Method	Description
final Optional<Long>	getOffset()
final Optional<Integer>	getPartition()
final Optional<K>	getStorageKey()
final Optional<String>	getTopic()
final void	setOffset(Long offset)
final void	setPartition(Integer partition)
final void	setStorageKey(K storageKey)
final void	setTopic(String topic)

Methods inherited from class java.lang.Object

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

Constructor Details

Context

public Context(K storageKey)

Context

protected Context(Context<K> anotherContext)

Creates a defensive copy of the Context

Parameters:

anotherContext - The Context which needs to be copied

Method Details

getTopic

public final Optional<String> getTopic()

setTopic

public final void setTopic(String topic)

getPartition

public final Optional<Integer> getPartition()

setPartition

public final void setPartition(Integer partition)

getStorageKey

public final Optional<K> getStorageKey()

setStorageKey

public final void setStorageKey(K storageKey)

getOffset

public final Optional<Long> getOffset()

setOffset

public final void setOffset(Long offset)