Package org.apache.kafka.clients.producer

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()
void	close()	See KafkaProducer.close()
void	close(Duration timeout)	See KafkaProducer.close(Duration)
void	commitTransaction()	See KafkaProducer.commitTransaction()
void	flush()	See KafkaProducer.flush()
void	initTransactions()	See KafkaProducer.initTransactions()
Map<MetricName,? extends Metric>	metrics()	See KafkaProducer.metrics()
List<PartitionInfo>	partitionsFor(String topic)	See KafkaProducer.partitionsFor(String)
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, String consumerGroupId)	Deprecated.
void	sendOffsetsToTransaction(Map<TopicPartition,OffsetAndMetadata> offsets, ConsumerGroupMetadata groupMetadata)	See KafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)

Method Details

initTransactions

void initTransactions()

See KafkaProducer.initTransactions()

beginTransaction

void beginTransaction()
               throws ProducerFencedException

See KafkaProducer.beginTransaction()

Throws:

ProducerFencedException

sendOffsetsToTransaction

@Deprecated
void sendOffsetsToTransaction(Map<TopicPartition,OffsetAndMetadata> offsets,
 String consumerGroupId)
                       throws ProducerFencedException

Deprecated.

See KafkaProducer.sendOffsetsToTransaction(Map, String)

Throws:

ProducerFencedException

sendOffsetsToTransaction

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

See KafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)

Throws:

ProducerFencedException

commitTransaction

void commitTransaction()
                throws ProducerFencedException

See KafkaProducer.commitTransaction()

Throws:

ProducerFencedException

abortTransaction

void abortTransaction()
               throws ProducerFencedException

See KafkaProducer.abortTransaction()

Throws:

ProducerFencedException

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()

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)