クラス 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>
デリゲートのラッパークラス。
作成者:
Gary Russell, Murali Reddy, Nakul Mishra, Artem Bilan, Chris Gilbert, Thomas Strau ß , Adrian Gygax, Soby Chacko, Jaeyeon Kim, Alexandros Papadakis

  • メソッドの詳細

    • send

      public FutureSE<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の send 

    • send

      public FutureSE<org.apache.kafka.clients.producer.RecordMetadata> send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record, org.apache.kafka.clients.producer.Callback callback)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の send 

    • flush

      public void flush()
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の flush 

    • partitionsFor

      public ListSE<org.apache.kafka.common.PartitionInfo> partitionsFor(StringSE topic)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の partitionsFor 

    • metrics

      public MapSE<org.apache.kafka.common.MetricName, ? extends org.apache.kafka.common.Metric> metrics()
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の metrics 

    • clientInstanceId

      public org.apache.kafka.common.Uuid clientInstanceId(DurationSE timeout)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の clientInstanceId 

    • initTransactions

      public void initTransactions()
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の initTransactions 

    • beginTransaction

      public void beginTransaction() throws org.apache.kafka.common.errors.ProducerFencedException
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の beginTransaction 
      例外:
      org.apache.kafka.common.errors.ProducerFencedException

    • 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.ProducerFencedException
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の sendOffsetsToTransaction 
      例外:
      org.apache.kafka.common.errors.ProducerFencedException

    • commitTransaction

      public void commitTransaction() throws org.apache.kafka.common.errors.ProducerFencedException
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の commitTransaction 
      例外:
      org.apache.kafka.common.errors.ProducerFencedException

    • abortTransaction

      public void abortTransaction() throws org.apache.kafka.common.errors.ProducerFencedException
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の abortTransaction 
      例外:
      org.apache.kafka.common.errors.ProducerFencedException

    • registerMetricForSubscription

      public void registerMetricForSubscription(org.apache.kafka.common.metrics.KafkaMetric kafkaMetric)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の registerMetricForSubscription 

    • unregisterMetricFromSubscription

      public void unregisterMetricFromSubscription(org.apache.kafka.common.metrics.KafkaMetric kafkaMetric)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の unregisterMetricFromSubscription 

    • close

      public void close()
      次で指定:
      インターフェース AutoCloseableSE の close 
      次で指定:
      インターフェース CloseableSE の close 
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の close 

    • close

      public void close(@Nullable DurationSE timeout)
      次で指定:
      インターフェース org.apache.kafka.clients.producer.Producer<K,V> の close 

    • toString

      public StringSE toString()
      オーバーライド:
      クラス ObjectSE の toString