インデックス

D

DeadLetterPublishingRecoverer - org.springframework.kafka.listener のクラス

失敗したレコードをデッドレタートピックに公開する ConsumerRecordRecoverer。

DeadLetterPublishingRecoverer(Function<ProducerRecord<?, ?>, KafkaOperations<?, ?>>, boolean, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - クラス org.springframework.kafka.listener. DeadLetterPublishingRecoverer のコンストラクター

失敗したコンシューマーレコードと例外を受け取り、KafkaOperations と、このインスタンスからの公開がトランザクションであるかどうかに関するフラグを返すテンプレート解決関数を使用してインスタンスを作成します。

DeadLetterPublishingRecoverer(Function<ProducerRecord<?, ?>, KafkaOperations<?, ?>>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - クラス org.springframework.kafka.listener. DeadLetterPublishingRecoverer のコンストラクター

失敗したコンシューマーレコードと例外を受け取り、KafkaOperations と、このインスタンスからの公開がトランザクションであるかどうかに関するフラグを返すテンプレート解決関数を使用してインスタンスを作成します。

DeadLetterPublishingRecoverer(Map<Class<?>, KafkaOperations<? extends Object, ? extends Object>>) - クラス org.springframework.kafka.listener. DeadLetterPublishingRecoverer のコンストラクター

提供されたテンプレートと、失敗したレコードの元のトピック ( "-dlt" が追加された) と失敗したレコードと同じパーティションに基づいて TopicPartition を返すデフォルトの宛先解決関数を使用してインスタンスを作成します。

DeadLetterPublishingRecoverer(Map<Class<?>, KafkaOperations<? extends Object, ? extends Object>>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - クラス org.springframework.kafka.listener. DeadLetterPublishingRecoverer のコンストラクター

提供されたテンプレートと宛先解決関数を使用してインスタンスを作成します。このインスタンスは、失敗したコンシューマーレコードと例外を受け取り、TopicPartition を返します。

DeadLetterPublishingRecoverer(KafkaOperations<? extends Object, ? extends Object>) - クラス org.springframework.kafka.listener. DeadLetterPublishingRecoverer のコンストラクター

提供されたテンプレートと、失敗したレコードの元のトピック ( "-dlt" が追加された) と失敗したレコードと同じパーティションに基づいて TopicPartition を返すデフォルトの宛先解決関数を使用してインスタンスを作成します。

DeadLetterPublishingRecoverer(KafkaOperations<? extends Object, ? extends Object>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - クラス org.springframework.kafka.listener. DeadLetterPublishingRecoverer のコンストラクター

提供されたテンプレートと宛先解決関数を使用してインスタンスを作成します。このインスタンスは、失敗したコンシューマーレコードと例外を受け取り、TopicPartition を返します。

DeadLetterPublishingRecoverer.ExceptionHeadersCreator - org.springframework.kafka.listener のインターフェース

これを使用して、出力レコードの例外ヘッダーの作成を完全に制御するカスタム実装を提供します。

DeadLetterPublishingRecoverer.HeaderNames - org.springframework.kafka.listener のクラス

生成されたレコードに追加されるヘッダーの名前のコンテナークラス。

DeadLetterPublishingRecoverer.HeaderNames.Builder - org.springframework.kafka.listener のクラス

DeadLetterPublishingRecoverer.HeaderNames を作成するための便利な API を提供します。

DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo - org.springframework.kafka.listener のクラス

スローされた例外に関連するデータのヘッダー。

DeadLetterPublishingRecoverer.HeaderNames.Builder.Original - org.springframework.kafka.listener のクラス

元のレコードに関連するデータのヘッダー。

DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo - org.springframework.kafka.listener のクラス

例外ヘッダーのヘッダー名。

DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd - org.springframework.kafka.listener の Enum クラス

追加するヘッダーを表すビット。

DeadLetterPublishingRecoverer.HeaderNames.Original - org.springframework.kafka.listener のクラス

元のレコードプロパティヘッダーのヘッダー名。

DeadLetterPublishingRecoverer.SingleRecordHeader - org.springframework.kafka.listener のクラス

通常の動作であるヘッダーに追加されるのではなく、このヘッダーが既存のヘッダーをこの名前に置き換える必要があることを示す Header。

deadLetterPublishingRecovererFactory(DestinationTopicResolver) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

レコードを特定の DestinationTopic に転送するための DeadLetterPublishingRecoverer の作成に使用される DeadLetterPublishingRecovererFactory を作成します。

DeadLetterPublishingRecovererFactory - org.springframework.kafka.retrytopic のクラス

DestinationTopicResolver を使用してメッセージを転送するために使用される DeadLetterPublishingRecoverer を作成および構成します。

DeadLetterPublishingRecovererFactory(DestinationTopicResolver) - クラス org.springframework.kafka.retrytopic. DeadLetterPublishingRecovererFactory のコンストラクター

DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator - org.springframework.kafka.retrytopic のインターフェース

このインターフェースを実装して、各 DeadLetterPublishingRecoverer を作成します。

DEBUG - Enum constant in enum class org.springframework.kafka.KafkaException.Level

デバッグ。

DEBUG - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level

デバッグ。

decorateFactory(ConcurrentKafkaListenerContainerFactory<?, ?>) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

付属の ConcurrentKafkaListenerContainerFactory を飾ります。

decorateFactory(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

decorateFactoryWithoutSettingContainerProperties(ConcurrentKafkaListenerContainerFactory<?, ?>, ListenerContainerFactoryConfigurer.Configuration) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

DEFAULT_ADMIN_TIMEOUT - Static variable in interface org.springframework.kafka.test.EmbeddedKafkaBroker

DEFAULT_ADMIN_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaKraftBroker

DEFAULT_BACK_OFF - Static variable in class org.springframework.kafka.listener.SeekUtils

デフォルトのバックオフ - 0 間隔の FixedBackOff と SeekUtils.DEFAULT_MAX_FAILURES - 1 回の再試行。

DEFAULT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper

型情報のデフォルトのヘッダー名。

DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.config.StreamsBuilderFactoryBean

閉じるタイムアウトの 10 seconds のデフォルト DurationSE。

DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.core.KafkaAdmin

デフォルトのクローズタイムアウト期間は 10 秒です。

DEFAULT_CLOSE_TIMEOUT - Static variable in class org.springframework.kafka.core.ProducerFactoryUtils

デフォルトのクローズタイムアウト (5 秒)。

DEFAULT_CONTENT_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper

コンテナーオブジェクトコンテンツ型情報のデフォルトのヘッダー名。

DEFAULT_DLT_HANDLER - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConfigurer

DLT でメッセージを処理するためのデフォルトの方法。

DEFAULT_DLT_SUFFIX - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants

dlt のデフォルトのサフィックス。

DEFAULT_HEADER_ATTEMPTS - Static variable in class org.springframework.kafka.retrytopic.RetryTopicHeaders

試行のデフォルトヘッダー。

DEFAULT_HEADER_BACKOFF_TIMESTAMP - Static variable in class org.springframework.kafka.retrytopic.RetryTopicHeaders

バックオフ期限のタイムスタンプのデフォルトのヘッダー。

DEFAULT_HEADER_ORIGINAL_TIMESTAMP - Static variable in class org.springframework.kafka.retrytopic.RetryTopicHeaders

元のメッセージのタイムスタンプのデフォルトヘッダー。

DEFAULT_KAFKA_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaListenerAnnotationBeanPostProcessor

デフォルトの KafkaListenerContainerFactory の Bean 名。

DEFAULT_KAFKA_TEMPLATE_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

内部で管理されるリスナーコンテナーファクトリの Bean 名。

DEFAULT_KEY_CLASSID_FIELD_NAME - Static variable in class org.springframework.kafka.support.mapping.AbstractJavaTypeMapper

マップキー型情報のデフォルトのヘッダー名。

DEFAULT_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

内部で管理されるリスナーコンテナーファクトリの Bean 名。

DEFAULT_MAX_ATTEMPTS - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants

最初の回数を含め、メッセージ処理を試行するデフォルトの回数。

DEFAULT_MAX_CONTENT_LOGGED - Static variable in class org.springframework.kafka.support.LoggingProducerListener

ログに記録されるデフォルトの最大コンテンツ。

DEFAULT_MAX_FAILURES - Static variable in class org.springframework.kafka.listener.SeekUtils

トピック / パーティション / オフセットが拒否される前に失敗する可能性がある回数。

DEFAULT_MONITOR_INTERVAL - Static variable in class org.springframework.kafka.listener.ContainerProperties

デフォルトの monitorInterval。

DEFAULT_NO_POLL_THRESHOLD - Static variable in class org.springframework.kafka.listener.ContainerProperties

デフォルトの noPollThreshold。

DEFAULT_PHASE - Static variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

リスナーコンテナー 2147483547 のデフォルト SmartLifecycle フェーズ。

DEFAULT_PHYSICAL_CLOSE_TIMEOUT - Static variable in interface org.springframework.kafka.core.ProducerFactory

デフォルトのクローズタイムアウト期間は 30 秒です。

DEFAULT_POLL_TIMEOUT - Static variable in interface org.springframework.kafka.core.KafkaOperations

KafkaOperations.receive(String, int, long) のデフォルトのタイムアウト。

DEFAULT_POLL_TIMEOUT - Static variable in class org.springframework.kafka.listener.ConsumerProperties

デフォルトの pollTimeout（ミリ秒）。

DEFAULT_PORT - Static variable in class org.springframework.kafka.test.core.BrokerAddress

DEFAULT_RETRY_SUFFIX - Static variable in class org.springframework.kafka.retrytopic.RetryTopicConstants

再試行トピックのデフォルトのサフィックス。

DEFAULT_RETRY_TOPIC_CONFIG_SUPPORT_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

必要に応じて、内部管理の再試行トピック構成サポートの Bean 名。

DEFAULT_SCHEDULER_WRAPPER_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

必要に応じて、内部的に登録されたスケジューララッパーの Bean 名。

DEFAULT_SHUTDOWN_TIMEOUT - Static variable in class org.springframework.kafka.listener.ContainerProperties

デフォルトの shutDownTimeout（ミリ秒）。

DEFAULT_STREAMS_BUILDER_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration

自動構成されたデフォルト StreamsBuilderFactoryBean の Bean 名。

DEFAULT_STREAMS_CONFIG_BEAN_NAME - Static variable in class org.springframework.kafka.annotation.KafkaStreamsDefaultConfiguration

デフォルトの StreamsBuilderFactoryBean Bean 定義に使用される StreamsConfig の Bean 名。

DEFAULT_ZK_CONNECTION_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

DEFAULT_ZK_SESSION_TIMEOUT - Static variable in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

デフォルトアフターロールバックプロセッサー <K, V> - org.springframework.kafka.listener のクラス

AfterRollbackProcessor のデフォルト実装。

DefaultAfterRollbackProcessor() - クラス org.springframework.kafka.listener. DefaultAfterRollbackProcessor のコンストラクター

トピック / パーティション / オフセットに対して 10 (maxFailures) が発生した後にレコードをログに記録するだけのデフォルトのリカバリを使用してインスタンスを構築します。

DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>) - クラス org.springframework.kafka.listener. DefaultAfterRollbackProcessor のコンストラクター

トピック / パーティション / オフセットに対して 10 (maxFailures) が発生した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff) - クラス org.springframework.kafka.listener. DefaultAfterRollbackProcessor のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, KafkaOperations<?, ?>, boolean) - クラス org.springframework.kafka.listener. DefaultAfterRollbackProcessor のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultAfterRollbackProcessor(BiConsumer<ConsumerRecord<?, ?>, Exception>, BackOff, BackOffHandler, KafkaOperations<?, ?>, boolean) - クラス org.springframework.kafka.listener. DefaultAfterRollbackProcessor のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultAfterRollbackProcessor(BackOff) - クラス org.springframework.kafka.listener. DefaultAfterRollbackProcessor のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後にレコードをログに記録するだけのデフォルトのリカバリを使用してインスタンスを構築します。

DefaultBackOffHandler - org.springframework.kafka.listener のクラス

デフォルト BackOffHandler ; バックオフのためにスレッドを一時停止します。

DefaultBackOffHandler() - クラス org.springframework.kafka.listener. DefaultBackOffHandler のコンストラクター

デフォルトバッチレコードアダプター <K, V> - org.springframework.kafka.listener.adapter のクラス

デフォルトの BatchToRecordAdapter 実装。提供されたリカバリが例外をスローした場合、バッチは中止されます。それ以外の場合は、次のレコードが処理されます。

DefaultBatchToRecordAdapter() - クラス org.springframework.kafka.listener.adapter. DefaultBatchToRecordAdapter のコンストラクター

失敗したレコードを単にログに記録するデフォルトのリカバリを使用してインスタンスを構築します。

DefaultBatchToRecordAdapter(ConsumerRecordRecoverer) - クラス org.springframework.kafka.listener.adapter. DefaultBatchToRecordAdapter のコンストラクター

提供されたリカバリを使用してインスタンスを構築します。

defaultBranch(Consumer<? super KStream<K, V>>) - クラス org.springframework.kafka.support のメソッド。KafkaStreamBrancher

デフォルトのブランチを定義します。

DefaultDestinationTopicProcessor - org.springframework.kafka.retrytopic のクラス

DestinationTopicProcessor インターフェースのデフォルト実装。

DefaultDestinationTopicProcessor(DestinationTopicResolver) - クラス org.springframework.kafka.retrytopic. DefaultDestinationTopicProcessor のコンストラクター

DefaultDestinationTopicResolver - org.springframework.kafka.retrytopic のクラス

DestinationTopicResolver インターフェースのデフォルト実装。

DefaultDestinationTopicResolver() - クラス org.springframework.kafka.retrytopic. DefaultDestinationTopicResolver のコンストラクター

デフォルトのクロックでインスタンスを構築します。

DefaultDestinationTopicResolver(Clock) - クラス org.springframework.kafka.retrytopic. DefaultDestinationTopicResolver のコンストラクター

指定されたクロックでインスタンスを構築します。

DefaultDestinationTopicResolver.DestinationTopicHolder - org.springframework.kafka.retrytopic のクラス

DefaultErrorHandler - org.springframework.kafka.listener のクラス

レコードリスナーの場合、残りのレコードの各トピックの現在のオフセットを探すエラーハンドラー。

DefaultErrorHandler() - クラス org.springframework.kafka.listener. DefaultErrorHandler のコンストラクター

デフォルトのバックオフ (9 回の再試行、遅延なし) で、トピック / パーティション / オフセットに対して 10 (maxFailures) が発生した後にレコードをログに記録するだけのデフォルトのリカバリを使用してインスタンスを構築します。

DefaultErrorHandler(ConsumerRecordRecoverer) - クラス org.springframework.kafka.listener. DefaultErrorHandler のコンストラクター

トピック / パーティション / オフセットに対して 10 (maxFailures) が発生した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultErrorHandler(ConsumerRecordRecoverer, BackOff) - クラス org.springframework.kafka.listener. DefaultErrorHandler のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultErrorHandler(ConsumerRecordRecoverer, BackOff, BackOffHandler) - クラス org.springframework.kafka.listener. DefaultErrorHandler のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後に呼び出される、提供されたリカバリを使用してインスタンスを構築します。

DefaultErrorHandler(BackOff) - クラス org.springframework.kafka.listener. DefaultErrorHandler のコンストラクター

backOff がトピック / パーティション / オフセットに対して STOP を返した後にレコードをログに記録するだけのデフォルトのリカバリを使用してインスタンスを構築します。

defaultFalse() - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier

デフォルトでは、一致しない型は true として分類されます。

defaultFalse(boolean) - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier

デフォルトでは、一致しない型は true として分類されます。

defaultFatalExceptionsList() - Static method in class org.springframework.kafka.listener.ExceptionClassifier

フレームワークのデフォルトの致命的な例外のリストを返します。

DefaultJackson2JavaTypeMapper - org.springframework.kafka.support.mapping のクラス

Jackson 2 型のマッパー。

DefaultJackson2JavaTypeMapper() - クラス org.springframework.kafka.support.mapping のコンストラクター。DefaultJackson2JavaTypeMapper

DefaultKafkaConsumerFactory<K, V> - org.springframework.kafka.core のクラス

ConsumerFactory.createConsumer() 呼び出しごとに、提供された MapSE configs およびオプションの Deserializer の新しい Consumer インスタンスを生成する ConsumerFactory 実装。

DefaultKafkaConsumerFactory(Map<String, Object>) - クラス org.springframework.kafka.core. DefaultKafkaConsumerFactory のコンストラクター

提供された構成でファクトリを構築します。

DefaultKafkaConsumerFactory(Map<String, Object>, Supplier<Deserializer<K>>, Supplier<Deserializer<V>>) - クラス org.springframework.kafka.core. DefaultKafkaConsumerFactory のコンストラクター

提供された構成とデシリアライザーのサプライヤーを使用してファクトリを構築します。

DefaultKafkaConsumerFactory(Map<String, Object>, Supplier<Deserializer<K>>, Supplier<Deserializer<V>>, boolean) - クラス org.springframework.kafka.core. DefaultKafkaConsumerFactory のコンストラクター

提供された構成とデシリアライザーのサプライヤーを使用してファクトリを構築します。

DefaultKafkaConsumerFactory(Map<String, Object>, Deserializer<K>, Deserializer<V>) - クラス org.springframework.kafka.core. DefaultKafkaConsumerFactory のコンストラクター

提供された構成とデシリアライザーを使用してファクトリを構築します。

DefaultKafkaConsumerFactory(Map<String, Object>, Deserializer<K>, Deserializer<V>, boolean) - クラス org.springframework.kafka.core. DefaultKafkaConsumerFactory のコンストラクター

提供された構成とデシリアライザーを使用してファクトリを構築します。

DefaultKafkaConsumerFactory.ExtendedKafkaConsumer - org.springframework.kafka.core のクラス

DefaultKafkaHeaderMapper - org.springframework.kafka.support のクラス

Apache Kafka のデフォルトのヘッダーマッパー。

DefaultKafkaHeaderMapper() - クラス org.springframework.kafka.support. DefaultKafkaHeaderMapper のコンストラクター

送信ヘッダーのデフォルトのオブジェクトマッパーとデフォルトのヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。

DefaultKafkaHeaderMapper(ObjectMapper) - クラス org.springframework.kafka.support. DefaultKafkaHeaderMapper のコンストラクター

提供されたオブジェクトマッパーと送信ヘッダーのデフォルトヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。

DefaultKafkaHeaderMapper(ObjectMapper, String...) - クラス org.springframework.kafka.support. DefaultKafkaHeaderMapper のコンストラクター

提供されたオブジェクトマッパーと送信ヘッダー用に提供されたヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。

DefaultKafkaHeaderMapper(String...) - クラス org.springframework.kafka.support. DefaultKafkaHeaderMapper のコンストラクター

デフォルトのオブジェクトマッパーと送信ヘッダー用に提供されたヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。

DefaultKafkaHeaderMapper.NonTrustedHeaderType - org.springframework.kafka.support のクラス

信頼できない型が原因でデコードできなかったヘッダーを表します。

DefaultKafkaListenerObservationConvention() - クラス org.springframework.kafka.support.micrometer のコンストラクター。KafkaListenerObservation.DefaultKafkaListenerObservationConvention

DefaultKafkaProducerFactory<K, V> - org.springframework.kafka.core のクラス

singleton 共有 Producer インスタンスの ProducerFactory 実装。

DefaultKafkaProducerFactory(Map<String, Object>) - クラス org.springframework.kafka.core. DefaultKafkaProducerFactory のコンストラクター

提供された構成でファクトリを構築します。

DefaultKafkaProducerFactory(Map<String, Object>, Supplier<Serializer<K>>, Supplier<Serializer<V>>) - クラス org.springframework.kafka.core. DefaultKafkaProducerFactory のコンストラクター

提供された構成と Serializer サプライヤーでファクトリを構築します。

DefaultKafkaProducerFactory(Map<String, Object>, Supplier<Serializer<K>>, Supplier<Serializer<V>>, boolean) - クラス org.springframework.kafka.core. DefaultKafkaProducerFactory のコンストラクター

提供された構成と Serializer サプライヤーでファクトリを構築します。

DefaultKafkaProducerFactory(Map<String, Object>, Serializer<K>, Serializer<V>) - クラス org.springframework.kafka.core. DefaultKafkaProducerFactory のコンストラクター

提供された構成と Serializer でファクトリを構築します。

DefaultKafkaProducerFactory(Map<String, Object>, Serializer<K>, Serializer<V>, boolean) - クラス org.springframework.kafka.core. DefaultKafkaProducerFactory のコンストラクター

提供された構成と Serializer でファクトリを構築します。

DefaultKafkaProducerFactory.CloseSafeProducer<K, V> - org.springframework.kafka.core のクラス

デリゲートのラッパークラス。

defaultKafkaStreamsBuilder(ObjectProvider<KafkaStreamsConfiguration>, ObjectProvider<StreamsBuilderFactoryBeanConfigurer>) - クラス org.springframework.kafka.annotation のメソッド。KafkaStreamsDefaultConfiguration

デフォルトの StreamsBuilderFactoryBean の場合は Bean。

DefaultKafkaTemplateObservationConvention() - クラス org.springframework.kafka.support.micrometer のコンストラクター。KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention

defaultPropertyOverrides() - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

デフォルトのコンシューマープロパティのオーバーライドに等しい PropertiesSE オブジェクトを返します。

DefaultTransactionIdSuffixStrategy - org.springframework.kafka.core のクラス

トランザクションプロデューサーサフィックスを管理するための TransactionIdSuffixStrategy 実装。

DefaultTransactionIdSuffixStrategy(int) - クラス org.springframework.kafka.core. DefaultTransactionIdSuffixStrategy のコンストラクター

指定されたキャッシュのサイズを使用してトランザクション ID サフィックス戦略を構築します。

delay() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic.Properties

delegate - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter

delegateType - Variable in class org.springframework.kafka.listener.adapter.AbstractDelegatingMessageListenerAdapter

DelegatingByTopicDeserializer - org.springframework.kafka.support.serializer のクラス

トピック名に基づいて他のデシリアライザーに委譲する Deserializer。

DelegatingByTopicDeserializer() - クラス org.springframework.kafka.support.serializer. DelegatingByTopicDeserializer のコンストラクター

コンシューマープロパティを使用して DelegatingByTopicDeserializer.configure(Map, boolean) で構成されるインスタンスを作成します。

DelegatingByTopicDeserializer(Map<Pattern, Deserializer<?>>, Deserializer<?>) - クラス org.springframework.kafka.support.serializer. DelegatingByTopicDeserializer のコンストラクター

デシリアライザーを委譲するために、提供されたトピック名パターンのマッピングを使用してインスタンスを構築します。

トピック直列化による委譲 <T> - org.springframework.kafka.support.serializer のクラス

トピックの直列化によって委譲するための共通コードを持つ基本クラス。

DelegatingByTopicSerialization() - クラス org.springframework.kafka.support.serializer. DelegatingByTopicSerialization のコンストラクター

DelegatingByTopicSerialization(Map<Pattern, T>, T) - クラス org.springframework.kafka.support.serializer. DelegatingByTopicSerialization のコンストラクター

DelegatingByTopicSerializer - org.springframework.kafka.support.serializer のクラス

トピックパターンに基づいて他のシリアライザーに委譲する Serializer。

DelegatingByTopicSerializer() - クラス org.springframework.kafka.support.serializer. DelegatingByTopicSerializer のコンストラクター

プロデューサープロパティ DelegatingByTopicSerialization.VALUE_SERIALIZATION_TOPIC_CONFIG および DelegatingByTopicSerialization.KEY_SERIALIZATION_TOPIC_CONFIG を使用して DelegatingByTopicSerializer.configure(Map, boolean) で構成されるインスタンスを作成します。

DelegatingByTopicSerializer(Map<Pattern, Serializer<?>>, Serializer<?>) - クラス org.springframework.kafka.support.serializer. DelegatingByTopicSerializer のコンストラクター

提供されたトピックパターンのマッピングを使用してインスタンスを構築し、シリアライザーを委譲します。

DelegatingByTypeSerializer - org.springframework.kafka.support.serializer のクラス

型に基づいてシリアライザーに委譲します。

DelegatingByTypeSerializer(Map<Class<?>, Serializer<?>>) - クラス org.springframework.kafka.support.serializer. DelegatingByTypeSerializer のコンストラクター

デリゲートのマップを使用してインスタンスを構築します。キーは完全に一致しました。

DelegatingByTypeSerializer(Map<Class<?>, Serializer<?>>, boolean) - クラス org.springframework.kafka.support.serializer. DelegatingByTypeSerializer のコンストラクター

デリゲートのマップを使用してインスタンスを作成します。

DelegatingDeserializer - org.springframework.kafka.support.serializer のクラス

直列化セレクターヘッダーに基づいて他のデシリアライザーに委譲する Deserializer。

DelegatingDeserializer() - クラス org.springframework.kafka.support.serializer. DelegatingDeserializer のコンストラクター

コンシューマープロパティ DelegatingSerializer.KEY_SERIALIZATION_SELECTOR_CONFIG および DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR_CONFIG を使用して DelegatingDeserializer.configure(Map, boolean) で構成されるインスタンスを作成します。

DelegatingDeserializer(Map<String, Deserializer<?>>) - クラス org.springframework.kafka.support.serializer. DelegatingDeserializer のコンストラクター

デシリアライザーを委譲するために、提供されたセレクターのマッピングを使用してインスタンスを構築します。

DelegatingInvocableHandler - org.springframework.kafka.listener.adapter のクラス

メッセージペイロード型に基づいて InvocableHandlerMethod に委譲します。

DelegatingInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod, Object, BeanExpressionResolver, BeanExpressionContext, BeanFactory, Validator) - クラス org.springframework.kafka.listener.adapter. DelegatingInvocableHandler のコンストラクター

Bean 用に提供されたハンドラーを使用してインスタンスを構築します。

DelegatingMessageListener<T> - org.springframework.kafka.listener のインターフェース

このインターフェースを実装するクラスにより、コンテナーは最終的なリスナーの型を決定できます。

DelegatingSerializer - org.springframework.kafka.support.serializer のクラス

直列化セレクターヘッダーに基づいて他のシリアライザーに委譲する Serializer。

DelegatingSerializer() - クラス org.springframework.kafka.support.serializer. DelegatingSerializer のコンストラクター

プロデューサープロパティ DelegatingSerializer.VALUE_SERIALIZATION_SELECTOR_CONFIG および DelegatingSerializer.KEY_SERIALIZATION_SELECTOR_CONFIG を使用して DelegatingSerializer.configure(Map, boolean) で構成されるインスタンスを作成します。

DelegatingSerializer(Map<String, Serializer<?>>) - クラス org.springframework.kafka.support.serializer. DelegatingSerializer のコンストラクター

提供されたセレクターのマッピングを使用してインスタンスを構築し、シリアライザーを委譲します。

DELIVERY_ATTEMPT - Static variable in class org.springframework.kafka.support.KafkaHeaders

受信メッセージの場合、コンテナーの再試行が有効になっていると、配信が試行されます。

deliveryAttempt(TopicPartitionOffset) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

deliveryAttempt(TopicPartitionOffset) - クラス org.springframework.kafka.listener のメソッド。CommonMixedErrorHandler

deliveryAttempt(TopicPartitionOffset) - インターフェース org.springframework.kafka.listener のメソッド。DeliveryAttemptAware

トピック / パーティション / オフセットの次の配信試行を返します。

deliveryAttempt(TopicPartitionOffset) - クラス org.springframework.kafka.listener のメソッド。FailedRecordProcessor

DeliveryAttemptAware - Interface in org.springframework.kafka.listener

このインターフェースを実装するコンポーネントは、次の配信試行を提供できます。

DeliveryAttemptAwareRetryListener - org.springframework.kafka.listener のクラス

RetryListener 実装用の DeliveryAttemptAwareRetryListener クラス。

DeliveryAttemptAwareRetryListener() - クラス org.springframework.kafka.listener. DeliveryAttemptAwareRetryListener のコンストラクター

deliveryAttemptHeader() - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler

このエラーハンドラーが配信試行ヘッダーをサポートしている場合は true を返します。

deliveryAttemptHeader() - クラス org.springframework.kafka.listener のメソッド。CommonMixedErrorHandler

deliveryAttemptHeader() - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

describeTo(Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordKeyMatcher

describeTo(Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordPartitionMatcher

describeTo(Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordTimestampMatcher

describeTo(Description) - クラス org.springframework.kafka.test.hamcrest のメソッド。KafkaMatchers.ConsumerRecordValueMatcher

describeTopics(String...) - クラス org.springframework.kafka.core のメソッド。KafkaAdmin

describeTopics(String...) - インターフェース org.springframework.kafka.core のメソッド。KafkaAdminOperations

これらのトピックの TopicDescription を取得します。

deserializationException(Headers, byte[], Exception, boolean) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils

レコードヘッダーに直列化された DeserializationException を入力します。

DeserializationException - Exception Class in org.springframework.kafka.support.serializer

逆直列化の失敗が発生したときに、コンシューマーレコードの値またはキーで例外が返されました。

DeserializationException(String, byte[], boolean, Throwable) - Constructor for exception class org.springframework.kafka.support.serializer.DeserializationException

提供されたプロパティを使用してインスタンスを構築します。

deserialize(String, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicDeserializer

deserialize(String, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingDeserializer

deserialize(String, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。ErrorHandlingDeserializer

deserialize(String, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

deserialize(String, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。ParseStringDeserializer

deserialize(String, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。RetryingDeserializer

deserialize(String, Headers, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicDeserializer

deserialize(String, Headers, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingDeserializer

deserialize(String, Headers, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。ErrorHandlingDeserializer

deserialize(String, Headers, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

deserialize(String, Headers, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。ParseStringDeserializer

deserialize(String, Headers, byte[]) - クラス org.springframework.kafka.support.serializer のメソッド。RetryingDeserializer

deserialize(String, Headers, ByteBuffer) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicDeserializer

deserialize(String, Headers, ByteBuffer) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingDeserializer

deserialize(String, Headers, ByteBuffer) - クラス org.springframework.kafka.support.serializer のメソッド。ParseStringDeserializer

deserialize(String, Headers, ByteBuffer) - クラス org.springframework.kafka.support.serializer のメソッド。RetryingDeserializer

deserializer() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

deserializer() - クラス org.springframework.kafka.support.serializer のメソッド。ToFromStringSerde

DESERIALIZER_EXCEPTION_HEADER_PREFIX - Static variable in class org.springframework.kafka.support.KafkaUtils

デシリアライズ例外のヘッダー名。

DESERIALIZER_EXCEPTION_HEADER_PREFIX - Static variable in class org.springframework.kafka.support.serializer.SerializationUtils

デシリアライズ例外のヘッダー名。

DESTINATION_TOPIC_RESOLVER_BEAN_NAME - Static variable in class org.springframework.kafka.retrytopic.RetryTopicBeanNames

内部管理された宛先トピックリゾルバーの Bean 名。

destinationsByTopicMap - クラス org.springframework.kafka.retrytopic の変数。DestinationTopicProcessor.Context

DestinationTopic - org.springframework.kafka.retrytopic のクラス

再試行トピックや dlt など、メッセージの転送先となる宛先トピックの表現。

DestinationTopic(String, DestinationTopic.Properties) - クラス org.springframework.kafka.retrytopic. DestinationTopic のコンストラクター

DestinationTopic(String, DestinationTopic, String, DestinationTopic.Type) - クラス org.springframework.kafka.retrytopic. DestinationTopic のコンストラクター

DestinationTopic.Properties - org.springframework.kafka.retrytopic のクラス

DestinationTopicContainer - Interface in org.springframework.kafka.retrytopic

DestinationTopic インスタンスを保存および取得するためのメソッドを提供します。

destinationTopicProcessor(DestinationTopicResolver) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

DestinationTopic インスタンスの処理に使用される DestinationTopicProcessor を作成し、提供された DestinationTopicResolver に格納します。

DestinationTopicProcessor - Interface in org.springframework.kafka.retrytopic

DestinationTopicProcessor は、提供された DestinationTopicProcessor.Context に DestinationTopic インスタンスを作成して登録し、コンテキストプロパティで呼び出されるコールバックインターフェースも提供します。

DestinationTopicProcessor.Context - org.springframework.kafka.retrytopic のクラス

DestinationTopicPropertiesFactory - org.springframework.kafka.retrytopic のクラス

提供された構成に基づいて DestinationTopic.Properties のリストを作成します。

DestinationTopicPropertiesFactory(String, String, List<Long>, BinaryExceptionClassifier, int, KafkaOperations<?, ?>, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long) - クラス org.springframework.kafka.retrytopic. DestinationTopicPropertiesFactory のコンストラクター

提供されたプロパティを使用してインスタンスを構築します。

DestinationTopicPropertiesFactory(String, String, List<Long>, BinaryExceptionClassifier, int, KafkaOperations<?, ?>, DltStrategy, TopicSuffixingStrategy, SameIntervalTopicReuseStrategy, long, Map<String, Set<Class<? extends Throwable>>>) - クラス org.springframework.kafka.retrytopic. DestinationTopicPropertiesFactory のコンストラクター

提供されたプロパティを使用してインスタンスを構築します。

DestinationTopicPropertiesFactory.DestinationTopicSuffixes - org.springframework.kafka.retrytopic のクラス

destinationTopicResolver() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

DestinationTopic インスタンスを格納するために使用される DestinationTopicResolver のインスタンスを作成し、特定のレコードの転送先を解決します。

destinationTopicResolver(ObjectProvider<RetryTopicComponentFactory>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport

特定の ConsumerRecord が再試行のために送信される DestinationTopic を解決するために、グローバル DestinationTopicResolver を返します。

DestinationTopicResolver - Interface in org.springframework.kafka.retrytopic

処理に失敗したメッセージの転送先となる宛先を解決するためのメソッドを提供します。

DestinationTopicSuffixes(String, String) - クラス org.springframework.kafka.retrytopic のコンストラクター。DestinationTopicPropertiesFactory.DestinationTopicSuffixes

destroy() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

destroy() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

destroy() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

destroy() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaProducerTemplate

destroy() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer

destroy() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

destroy() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicSchedulerWrapper

destroy() - クラス org.springframework.kafka.security.jaas のメソッド。KafkaJaasLoginModuleInitializer

destroy() - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder

タイマーを削除します。

destroy() - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

destroy() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

destroy() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

determineInferredType(Method) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

サブクラスはこのメソッドをオーバーライドして、別のメカニズムを使用してペイロード変換のターゲット型を決定できます。

determineListenerType(Object) - Static method in class org.springframework.kafka.listener.ListenerUtils

リスナーの型を判別します。

determineSendTimeout(Map<String, Object>, long, long) - Static method in class org.springframework.kafka.support.KafkaUtils

レコードを送信するときに使用するタイムアウトを返します。

determineSendTimeout(KafkaOperations<?, ?>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

テンプレートのプロデューサーファクトリと DeadLetterPublishingRecoverer.setWaitForSendResultTimeout(Duration) に基づいて送信タイムアウトを決定します。

DLT_EXCEPTION_CAUSE_FQCN - Static variable in class org.springframework.kafka.support.KafkaHeaders

公開されたレコードの例外原因クラス名が、デッドレタートピックに送信されました。

DLT_EXCEPTION_FQCN - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに送信された、公開されたレコードの例外クラス名。

DLT_EXCEPTION_MESSAGE - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの例外メッセージ。

DLT_EXCEPTION_STACKTRACE - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの例外スタックトレース。

DLT_KEY_EXCEPTION_FQCN - Static variable in class org.springframework.kafka.support.KafkaHeaders

公開されたレコードの例外クラス名が、キーの逆直列化例外を伴うデッドレタートピックに送信されました。

DLT_KEY_EXCEPTION_MESSAGE - Static variable in class org.springframework.kafka.support.KafkaHeaders

キーの逆直列化例外を使用して、デッドレタートピックに公開されたレコードの例外メッセージ。

DLT_KEY_EXCEPTION_STACKTRACE - Static variable in class org.springframework.kafka.support.KafkaHeaders

キーの逆直列化例外を使用して、配信不能トピックに公開されたレコードの例外スタックトレース。

DLT_ORIGINAL_CONSUMER_GROUP - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードを消費できなかったコンシューマーグループ。

DLT_ORIGINAL_OFFSET - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの元のオフセット。

DLT_ORIGINAL_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの元のパーティション。

DLT_ORIGINAL_TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの元のタイムスタンプ。

DLT_ORIGINAL_TIMESTAMP_TYPE - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの元のタイムスタンプ型。

DLT_ORIGINAL_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders

デッドレタートピックに公開されたレコードの元のトピック。

DltHandler - Annotation Interface in org.springframework.kafka.annotation

DLT トピックメッセージを処理するメソッドを決定するためのアノテーション。

dltHandlerMethod(String, String) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

DLT ハンドラーメソッドを設定します。

dltHandlerMethod(EndpointHandlerMethod) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

DLT ハンドラーメソッドを設定します。

dltProcessingFailureStrategy(DltStrategy) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

DltStrategy を構成します。

dltRoutingRules(Map<String, Set<Class<? extends Throwable>>>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

メッセージ処理中に構成された例外がスローされた場合に、メッセージがカスタム DLT にリダイレクトされるように DLT ルーティングルールを設定するように構成します。

dltStrategy() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

DLT を作成するかどうか、および配信が失敗した場合、単にあきらめた場合は DLT に再配信します。

DltStrategy - Enum Class in org.springframework.kafka.retrytopic

DLT 処理を処理するための戦略。

dltSuffix(String) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

DLT トピックに追加するサフィックスを構成します。

dltTopicSuffix() - Element in annotation interface org.springframework.kafka.annotation.RetryableTopic

dlt トピックを生成するためにメイントピックに追加されるサフィックス。

doBegin(Object, TransactionDefinition) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doCleanupAfterCompletion(Object) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doCommit(DefaultTransactionStatus) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doCreateManager(ListenerContainerRegistry) - クラス org.springframework.kafka.listener のメソッド。AbstractKafkaBackOffManagerFactory

doCreateManager(ListenerContainerRegistry) - クラス org.springframework.kafka.listener のメソッド。ContainerPartitionPausingBackOffManagerFactory

doGetTransaction() - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doHandle(Exception, ConsumerRecords<?, ?>, Consumer<?, ?>, MessageListenerContainer, Runnable) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

doInKafka(Producer<K, V>) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations.ProducerCallback

doInOperations(KafkaOperations<K, V>) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations.OperationsCallback

doInvoke(Object...) - クラス org.springframework.kafka.listener.adapter のメソッド。KotlinAwareInvocableHandlerMethod

doNotAutoCreateRetryTopics() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

トピックを自動作成しないようにトピック作成動作を構成します。

doNotConfigureDlt() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

DltStrategy を DltStrategy.NO_DLT に構成します。

doNotRetryOnDltFailure() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

DltStrategy を DltStrategy.FAIL_ON_ERROR に構成します。

dontRemoveTypeHeaders() - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

型情報ヘッダーを削除しないでください。

dontRemoveTypeHeaders() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

デシリアライズ後に型情報ヘッダーを削除しないでください。

doOnConsumer(Function<Consumer<K, V>, ? extends T>) - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

doOnProducer(Function<Producer<K, V>, ? extends T>) - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaProducerTemplate

doResume(Object, Object) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doRollback(DefaultTransactionStatus) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doSeeks(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, Exception, boolean, BiPredicate<ConsumerRecord<?, ?>, Exception>, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils

レコードを最も早い位置にシークし、オプションで最初の位置をスキップします。

doSeeks(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, Exception, boolean, RecoveryStrategy, MessageListenerContainer, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils

レコードを最も早い位置にシークし、オプションで最初の位置をスキップします。

doSeeksToBegin(List<ConsumerRecord<?, ?>>, Consumer<?, ?>, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils

開始位置までレコードをシークします。オプションで最初のレコードをスキップします。

doSend(ProducerRecord<K, V>, Observation) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

プロデューサーレコードを送信します。

doSetRollbackOnly(DefaultTransactionStatus) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doStart() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

doStart() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer

doStart() - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer

doStop(Runnable) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

doStop(Runnable, boolean) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

コンテナーを正常または異常に停止します。

doStop(Runnable, boolean) - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer

doStop(Runnable, boolean) - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer

doSuspend(Object) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

doWithAdmin(Consumer<AdminClient>) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

AdminClient を作成します。コールバックを呼び出し、管理者を確実に閉じます。

doWithAdmin(Consumer<AdminClient>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

AdminClient を作成します。コールバックを呼び出し、管理者を確実に閉じます。

doWithAdminFunction(Function<AdminClient, T>) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

AdminClient を作成します。コールバックを呼び出し、管理者を確実に閉じます。

doWithAdminFunction(Function<AdminClient, T>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

AdminClient を作成します。コールバックを呼び出し、管理者を確実に閉じます。