reactor.kafka.sender

Interface TransactionManager

public interface TransactionManager

Method Summary

Modifier and Type	Method and Description
<T> Mono<T>	abort() Aborts the current transaction.
<T> Mono<T>	begin() Begins a new transaction.
<T> Mono<T>	commit() Commits the current transaction.
Scheduler	scheduler() Returns the scheduler associated with this transaction instance.
default <T> Mono<T>	sendOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, org.apache.kafka.clients.consumer.ConsumerGroupMetadata metadata) Sends provided offsets to the consumer offsets topic.
<T> Mono<T>	sendOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, String consumerGroupId) Deprecated. in favor of #sendOffsets(Map, ConsumerGroupMetadata)
default TransactionManager	transactionComplete(Consumer<Boolean> txComplete) A callback to indicate a commit or rollback has completed, true for commit.

Method Detail

begin

<T> Mono<T> begin()

Begins a new transaction. See KafkaProducer.beginTransaction() for more details. No other operations may be performed on this sender while this begin operation is in progress.

Example usage:

 
 transactionManager = kafkaSender.transactionManager();
 transactionManager.begin()
                   .then(kafkaSender.send(outboundFlux))
                   .then(transactionManager.commit());
 
 

Returns:

empty Mono that completes when the transaction has started

sendOffsets

@Deprecated
<T> Mono<T> sendOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
                                    String consumerGroupId)

Deprecated. in favor of #sendOffsets(Map, ConsumerGroupMetadata)

Sends provided offsets to the consumer offsets topic. Offsets are updated within the current transaction. See KafkaProducer.sendOffsetsToTransaction(Map, String) for details on updating consumer offsets within a transaction.

Parameters:

offsets - Consumer offsets to update

consumerGroupId - The consumer group id for which offsets are updated

Returns:

empty Mono that completes when the offsets have been sent to the consumer offsets topic. The offsets will be committed when the current transaction is committed.

sendOffsets

default <T> Mono<T> sendOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
                                org.apache.kafka.clients.consumer.ConsumerGroupMetadata metadata)

Sends provided offsets to the consumer offsets topic. Offsets are updated within the current transaction. See KafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata) for details on updating consumer offsets within a transaction.

Parameters:

offsets - Consumer offsets to update

metadata - The consumer group metadata

Returns:

empty Mono that completes when the offsets have been sent to the consumer offsets topic. The offsets will be committed when the current transaction is committed.

Since:

1.3.9

commit

<T> Mono<T> commit()

Commits the current transaction. See KafkaProducer.commitTransaction() for details.

Returns:

empty Mono that completes when the transaction is committed.

abort

<T> Mono<T> abort()

Aborts the current transaction. See KafkaProducer.abortTransaction() for details.

Returns:

empty Mono that completes when the transaction is aborted.

scheduler

Scheduler scheduler()

Returns the scheduler associated with this transaction instance. All transactional operations on this transaction and the parent KafkaSender are published on this scheduler. This scheduler is configured using SenderOptions.scheduler(Scheduler) and it must be single threaded.

Returns:

the scheduler associated with this transaction instance.

transactionComplete

default TransactionManager transactionComplete(Consumer<Boolean> txComplete)

A callback to indicate a commit or rollback has completed, true for commit.

Parameters:

txComplete - the commitComplete to set.

Returns:

the manager;

Since:

1.3.12