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()
void	close() Close this producer
void	close(long timeout, TimeUnit unit) Tries to close the producer cleanly within the specified timeout.
void	commitTransaction() See KafkaProducer.commitTransaction()
void	flush() Flush any accumulated records from the producer.
void	initTransactions() See KafkaProducer.initTransactions()
Map<MetricName,? extends Metric>	metrics() Return a map of metrics maintained by the producer
List<PartitionInfo>	partitionsFor(String topic) Get a list of partitions for the given topic for custom partition assignment.
Future<RecordMetadata>	send(ProducerRecord<K,V> record) Send the given record asynchronously and return a future which will eventually contain the response information.
Future<RecordMetadata>	send(ProducerRecord<K,V> record, Callback callback) Send a record and invoke the given callback when the record has been acknowledged by the server
void	sendOffsetsToTransaction(Map<TopicPartition,OffsetAndMetadata> offsets, String consumerGroupId) See KafkaProducer.sendOffsetsToTransaction(Map, String)

Method Detail

initTransactions

void initTransactions()

See KafkaProducer.initTransactions()

beginTransaction

void beginTransaction()
               throws ProducerFencedException

See KafkaProducer.beginTransaction()

Throws:

ProducerFencedException

sendOffsetsToTransaction

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

See KafkaProducer.sendOffsetsToTransaction(Map, String)

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)

Send the given record asynchronously and return a future which will eventually contain the response information.

Parameters:

record - The record to send

Returns:

A future which will eventually contain the response information

send

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

Send a record and invoke the given callback when the record has been acknowledged by the server

flush

void flush()

Flush any accumulated records from the producer. Blocks until all sends are complete.

partitionsFor

List<PartitionInfo> partitionsFor(String topic)

Get a list of partitions for the given topic for custom partition assignment. The partition metadata will change over time so this list should not be cached.

metrics

Map<MetricName,? extends Metric> metrics()

Return a map of metrics maintained by the producer

close

void close()

Close this producer

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

close

void close(long timeout,
           TimeUnit unit)

Tries to close the producer cleanly within the specified timeout. If the close does not complete within the timeout, fail any pending send requests and force close the producer.