K - the key type.V - the value type.protected static class DefaultKafkaProducerFactory.CloseSafeProducer<K,V>
extends java.lang.Object
implements org.apache.kafka.clients.producer.Producer<K,V>
| Modifier and Type | Method and Description |
|---|---|
void |
abortTransaction() |
void |
beginTransaction() |
void |
close() |
void |
close(java.time.Duration timeout) |
void |
commitTransaction() |
void |
flush() |
void |
initTransactions() |
java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> |
metrics() |
java.util.List<org.apache.kafka.common.PartitionInfo> |
partitionsFor(java.lang.String topic) |
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> |
send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record) |
java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> |
send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record,
org.apache.kafka.clients.producer.Callback callback) |
void |
sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata) |
void |
sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
java.lang.String consumerGroupId) |
java.lang.String |
toString() |
public java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
public java.util.concurrent.Future<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, org.apache.kafka.clients.producer.Callback callback)
public void flush()
public java.util.List<org.apache.kafka.common.PartitionInfo> partitionsFor(java.lang.String topic)
public java.util.Map<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics()
public void initTransactions()
public void beginTransaction()
throws org.apache.kafka.common.errors.ProducerFencedException
public void sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
java.lang.String consumerGroupId)
throws org.apache.kafka.common.errors.ProducerFencedException
public void sendOffsetsToTransaction(java.util.Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata)
throws org.apache.kafka.common.errors.ProducerFencedException
public void commitTransaction()
throws org.apache.kafka.common.errors.ProducerFencedException
public void abortTransaction()
throws org.apache.kafka.common.errors.ProducerFencedException
public void close()
public void close(@Nullable
java.time.Duration timeout)
public java.lang.String toString()
toString in class java.lang.Object