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 |
close(long timeout,
java.util.concurrent.TimeUnit unit)
Deprecated.
|
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,
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 commitTransaction() throws org.apache.kafka.common.errors.ProducerFencedException
public void abortTransaction() throws org.apache.kafka.common.errors.ProducerFencedException
public void close()
@Deprecated public void close(long timeout, @Nullable java.util.concurrent.TimeUnit unit)
public void close(@Nullable java.time.Duration timeout)
public java.lang.String toString()
toString
in class java.lang.Object