org.apache.kafka.connect.source

Interface TransactionContext

public interface TransactionContext

Provided to source tasks to allow them to define their own producer transaction boundaries when exactly-once support is enabled.

Method Summary

Modifier and Type	Method and Description
void	abortTransaction() Requests a transaction abort after the next batch of records from SourceTask.poll().
void	abortTransaction(SourceRecord record) Requests a transaction abort after a source record is processed.
void	commitTransaction() Request a transaction commit after the next batch of records from SourceTask.poll() is processed.
void	commitTransaction(SourceRecord record) Request a transaction commit after a source record is processed.

Method Detail

commitTransaction

void commitTransaction()

Request a transaction commit after the next batch of records from SourceTask.poll() is processed.

commitTransaction

void commitTransaction(SourceRecord record)

Request a transaction commit after a source record is processed. The source record will be the last record in the committed transaction.

Parameters:

record - the record to commit the transaction after; may not be null.

abortTransaction

void abortTransaction()

Requests a transaction abort after the next batch of records from SourceTask.poll(). All of the records in that transaction will be discarded and will not appear in a committed transaction. However, offsets for that transaction will still be committed so than the records in that transaction are not reprocessed. If the data should instead be reprocessed, the task should not invoke this method and should instead throw an exception.

abortTransaction

void abortTransaction(SourceRecord record)

Requests a transaction abort after a source record is processed. The source record will be the last record in the aborted transaction. All of the records in that transaction will be discarded and will not appear in a committed transaction. However, offsets for that transaction will still be committed so that the records in that transaction are not reprocessed. If the data should be reprocessed, the task should not invoke this method and should instead throw an exception.

Parameters:

record - the record to abort the transaction after; may not be null.