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 and 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	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, ConsumerGroupMetadata groupMetadata) See KafkaProducer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)
void	sendOffsetsToTransaction(Map<TopicPartition,OffsetAndMetadata> offsets, String consumerGroupId) Deprecated.

Method Detail

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

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)