java.lang.AutoCloseable, java.io.CloseableKafkaProducer, MockProducerpublic interface Producer<K,V>
extends java.io.Closeable
KafkaProducerKafkaProducer,
MockProducer| Modifier and Type | Method | Description |
|---|---|---|
void |
abortTransaction() |
|
void |
beginTransaction() |
|
void |
close() |
|
void |
close(long timeout,
java.util.concurrent.TimeUnit unit) |
|
void |
commitTransaction() |
|
void |
flush() |
|
void |
initTransactions() |
|
java.util.Map<MetricName,? extends Metric> |
metrics() |
|
java.util.List<PartitionInfo> |
partitionsFor(java.lang.String topic) |
|
java.util.concurrent.Future<RecordMetadata> |
send(ProducerRecord<K,V> record) |
|
java.util.concurrent.Future<RecordMetadata> |
send(ProducerRecord<K,V> record,
Callback callback) |
|
void |
sendOffsetsToTransaction(java.util.Map<TopicPartition,OffsetAndMetadata> offsets,
java.lang.String consumerGroupId) |
void initTransactions()
void beginTransaction()
throws ProducerFencedException
ProducerFencedExceptionvoid sendOffsetsToTransaction(java.util.Map<TopicPartition,OffsetAndMetadata> offsets, java.lang.String consumerGroupId) throws ProducerFencedException
ProducerFencedExceptionvoid commitTransaction()
throws ProducerFencedException
ProducerFencedExceptionvoid abortTransaction()
throws ProducerFencedException
ProducerFencedExceptionjava.util.concurrent.Future<RecordMetadata> send(ProducerRecord<K,V> record)
java.util.concurrent.Future<RecordMetadata> send(ProducerRecord<K,V> record, Callback callback)
void flush()
java.util.List<PartitionInfo> partitionsFor(java.lang.String topic)
java.util.Map<MetricName,? extends Metric> metrics()
void close()
close in interface java.lang.AutoCloseableclose in interface java.io.Closeablevoid close(long timeout,
java.util.concurrent.TimeUnit unit)