パッケージ org.springframework.kafka.core

クラス 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>
デリゲートのラッパークラス。

  • 方法の詳細

    • 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