Interface Producer<K,V>

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

KafkaProducer, MockProducer

public interface Producer<K,V>
extends Closeable

The interface for the KafkaProducer

See Also:

• KafkaProducer
• MockProducer

Method Summary

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

Method Details

initTransactions

default void initTransactions()

See initTransactions()

initTransactions

void initTransactions(boolean keepPreparedTxn)

See KafkaProducer.initTransactions(boolean)

beginTransaction

void beginTransaction()
               throws ProducerFencedException

See KafkaProducer.beginTransaction()

Throws:

ProducerFencedException

sendOffsetsToTransaction

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

See KafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)

Throws:

ProducerFencedException

prepareTransaction

PreparedTxnState prepareTransaction()
                             throws ProducerFencedException

See KafkaProducer.prepareTransaction()

Throws:

ProducerFencedException

commitTransaction

void commitTransaction()
                throws ProducerFencedException

See KafkaProducer.commitTransaction()

Throws:

ProducerFencedException

abortTransaction

void abortTransaction()
               throws ProducerFencedException

See KafkaProducer.abortTransaction()

Throws:

ProducerFencedException

completeTransaction

void completeTransaction(PreparedTxnState preparedTxnState)
                  throws ProducerFencedException

See KafkaProducer.completeTransaction(PreparedTxnState)

Throws:

ProducerFencedException

registerMetricForSubscription

void registerMetricForSubscription(KafkaMetric metric)

See Also:

• KafkaProducer.registerMetricForSubscription(KafkaMetric)

unregisterMetricFromSubscription

void unregisterMetricFromSubscription(KafkaMetric metric)

See Also:

• KafkaProducer.unregisterMetricFromSubscription(KafkaMetric)

send

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

See KafkaProducer.send(ProducerRecord)

send

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

See KafkaProducer.send(ProducerRecord, Callback)

flush

void flush()

See KafkaProducer.flush()

partitionsFor

List<PartitionInfo> partitionsFor(String topic)

See KafkaProducer.partitionsFor(String)

metrics

Map<MetricName, ? extends Metric> metrics()

See KafkaProducer.metrics()

clientInstanceId

Uuid clientInstanceId(Duration timeout)

See KafkaProducer.clientInstanceId(Duration)}

close

void close()

See KafkaProducer.close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

close

void close(Duration timeout)

See KafkaProducer.close(Duration)