クラス DefaultKafkaProducerFactory.CloseSafeProducer<K, V>
java.lang.ObjectSE
org.springframework.kafka.core.DefaultKafkaProducerFactory.CloseSafeProducer<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 実装されたすべてのインターフェース:
CloseableSE
、AutoCloseableSE
、org.apache.kafka.clients.producer.Producer<K,
V>
- 含まれているクラス:
- DefaultKafkaProducerFactory<K,
V>
protected static class DefaultKafkaProducerFactory.CloseSafeProducer<K,V>
extends ObjectSE
implements org.apache.kafka.clients.producer.Producer<K,V>
デリゲートのラッパークラス。
メソッドのサマリー
修飾子と型メソッド説明void
void
org.apache.kafka.common.Uuid
clientInstanceId
(DurationSE timeout) void
close()
void
close
(DurationSE timeout) void
void
flush()
void
MapSE<org.apache.kafka.common.MetricName,
? extends org.apache.kafka.common.Metric> metrics()
ListSE<org.apache.kafka.common.PartitionInfo>
partitionsFor
(StringSE topic) FutureSE<org.apache.kafka.clients.producer.RecordMetadata>
FutureSE<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
(MapSE<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, StringSE consumerGroupId) void
sendOffsetsToTransaction
(MapSE<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata) toString()
メソッドの詳細
send
send
flush
public void flush()partitionsFor
metrics
clientInstanceId
initTransactions
public void initTransactions()beginTransaction
public void beginTransaction() throws org.apache.kafka.common.errors.ProducerFencedExceptionsendOffsetsToTransaction
sendOffsetsToTransaction
public void sendOffsetsToTransaction(MapSE<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.ProducerFencedExceptioncommitTransaction
public void commitTransaction() throws org.apache.kafka.common.errors.ProducerFencedExceptionabortTransaction
public void abortTransaction() throws org.apache.kafka.common.errors.ProducerFencedExceptionclose
public void close()- 次で指定:
- インターフェース
AutoCloseableSE
のclose
- 次で指定:
- インターフェース
CloseableSE
のclose
- 次で指定:
- インターフェース
org.apache.kafka.clients.producer.Producer<K,
のV> close
close
toString