Class RecoveringTransactionalProducer<K,V>

java.lang.Object

io.micronaut.configuration.kafka.RecoveringTransactionalProducer<K,V>

Type Parameters:

K - The key type

V - The value type

All Implemented Interfaces:

Closeable, AutoCloseable, Producer<K,V>

@Internal
public final class RecoveringTransactionalProducer<K,V>
extends Object
implements Producer<K,V>

Wraps a transactional Kafka producer and recreates it when Kafka expires the transactional id.

Constructor Summary

Constructors

Constructor	Description
RecoveringTransactionalProducer(Supplier<Producer<K,V>> producerSupplier, @Nullable String transactionalId)

Method Summary

Modifier and Type	Method	Description
void	abortTransaction()
void	beginTransaction()
Uuid	clientInstanceId(Duration timeout)
void	close()
void	close(Duration timeout)
void	commitTransaction()
void	flush()
void	initTransactions()
Map<MetricName, ? extends Metric>	metrics()
List<PartitionInfo>	partitionsFor(String topic)
void	registerMetricForSubscription(KafkaMetric metric)
Future<RecordMetadata>	send(ProducerRecord<K,V> record)
Future<RecordMetadata>	send(ProducerRecord<K,V> record, Callback callback)
void	sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets, ConsumerGroupMetadata groupMetadata)
void	unregisterMetricFromSubscription(KafkaMetric metric)

Methods inherited from class Object

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

Constructor Details

RecoveringTransactionalProducer

public RecoveringTransactionalProducer(Supplier<Producer<K,V>> producerSupplier,
 @Nullable String transactionalId)

Method Details

initTransactions

public void initTransactions()

Specified by:

initTransactions in interface Producer<K,V>

beginTransaction

public void beginTransaction()

Specified by:

beginTransaction in interface Producer<K,V>

sendOffsetsToTransaction

public void sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata> offsets,
 ConsumerGroupMetadata groupMetadata)

Specified by:

sendOffsetsToTransaction in interface Producer<K,V>

commitTransaction

public void commitTransaction()

Specified by:

commitTransaction in interface Producer<K,V>

abortTransaction

public void abortTransaction()

Specified by:

abortTransaction in interface Producer<K,V>

registerMetricForSubscription

public void registerMetricForSubscription(KafkaMetric metric)

Specified by:

registerMetricForSubscription in interface Producer<K,V>

unregisterMetricFromSubscription

public void unregisterMetricFromSubscription(KafkaMetric metric)

Specified by:

unregisterMetricFromSubscription in interface Producer<K,V>

send

public Future<RecordMetadata> send(ProducerRecord<K,V> record)

Specified by:

send in interface Producer<K,V>

send

public Future<RecordMetadata> send(ProducerRecord<K,V> record,
 Callback callback)

Specified by:

send in interface Producer<K,V>

flush

public void flush()

Specified by:

flush in interface Producer<K,V>

partitionsFor

public List<PartitionInfo> partitionsFor(String topic)

Specified by:

partitionsFor in interface Producer<K,V>

metrics

public Map<MetricName, ? extends Metric> metrics()

Specified by:

metrics in interface Producer<K,V>

clientInstanceId

public Uuid clientInstanceId(Duration timeout)

Specified by:

clientInstanceId in interface Producer<K,V>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Producer<K,V>

close

public void close(Duration timeout)

Specified by:

close in interface Producer<K,V>