Producer (clients 7.5.12-ce API)

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

All Methods Instance Methods Abstract Methods Deprecated Methods
Modifier and Type	Method and 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, 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()

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)

Interface Producer<K,V>

Method Summary

Method Detail

initTransactions

beginTransaction

sendOffsetsToTransaction

sendOffsetsToTransaction

commitTransaction

abortTransaction

send

send

flush

partitionsFor

metrics

close

close