インデックス

K

KAFKA_CLIENT_CONTEXT_NAME - Static variable in class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer

kafka クライアント構成エントリのキー。

KAFKA_CONSUMER_BACK_OFF_MANAGER_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils

内部管理された Kafka コンシューマーバックオフマネージャーの Bean 名。

KAFKA_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils

内部で管理されている Kafka リスナーアノテーションプロセッサーの Bean 名。

KAFKA_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.kafka.config.KafkaListenerConfigUtils

内部で管理されている Kafka リスナーエンドポイントレジストリの Bean 名。

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

アプリケーションコンテキストで定義されたトピックを作成するために AdminClient に委譲する管理者。

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

提供された構成に基づいて、AdminClient を使用してインスタンスを作成します。

KafkaAdmin.NewTopics - org.springframework.kafka.core のクラス

複数のトピックを単一の Bean として宣言するのを容易にする NewTopic のコレクションのラッパー。

KafkaAdminOperations - Interface in org.springframework.kafka.core

AdminClient をラップする多くの便利なメソッドを提供します。

KafkaAvroBeanRegistrationAotProcessor - org.springframework.kafka.aot のクラス

Apache Kafka リスナーの Avro 型を検出して登録します。

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

KafkaAwareTransactionManager< K , V > - Interface in org.springframework.kafka.transaction

ProducerFactory を提供できるトランザクションマネージャー。

KafkaBackoffAwareMessageListenerAdapter< K , V > - Class in org.springframework.kafka.listener.adapter

バックオフ dueTimestamp ヘッダーを検索し、必要に応じてバックオフする KafkaConsumerBackoffManager インスタンスを呼び出す AcknowledgingConsumerAwareMessageListener 実装。

KafkaBackoffAwareMessageListenerAdapter(MessageListener<K, V>, KafkaConsumerBackoffManager, String, String, Clock) - クラス org.springframework.kafka.listener.adapter. KafkaBackoffAwareMessageListenerAdapter のコンストラクター

このリスナーアダプターの構成。

KafkaBackoffAwareMessageListenerAdapter(MessageListener<K, V>, KafkaConsumerBackoffManager, String, Clock) - クラス org.springframework.kafka.listener.adapter. KafkaBackoffAwareMessageListenerAdapter のコンストラクター

KafkaBackoffException - Exception in org.springframework.kafka.listener

backOff が原因でコンシューマーがメッセージをまだ消費していない場合にスローされる例外。

KafkaBackoffException(String, TopicPartition, String, long) - Constructor for exception org.springframework.kafka.listener.KafkaBackoffException

BackOff イベントからのデータを持つコンストラクター。

kafkaBackOffManagerFactory(ListenerContainerRegistry, ApplicationContext) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

パーティションのバックオフに使用される KafkaConsumerBackoffManager インスタンスの作成に使用される KafkaBackOffManagerFactory を作成します。

KafkaBackOffManagerFactory - Interface in org.springframework.kafka.listener

KafkaBackOffManagerFactory インスタンスを作成します。

KafkaBootstrapConfiguration - org.springframework.kafka.annotation のクラス

Spring の @KafkaListener アノテーションを処理できる KafkaListenerAnnotationBeanPostProcessor Bean を登録する ImportBeanDefinitionRegistrar クラス。

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

KafkaConditions - org.springframework.kafka.test.assertj のクラス

AssertJ カスタム Conditions.

KafkaConditions.ConsumerRecordKeyCondition <K> - org.springframework.kafka.test.assertj のクラス

KafkaConditions.ConsumerRecordKeyValueCondition < K、V > - org.springframework.kafka.test.assertj のクラス

KafkaConditions.ConsumerRecordPartitionCondition - org.springframework.kafka.test.assertj のクラス

KafkaConditions.ConsumerRecordTimestampCondition - org.springframework.kafka.test.assertj のクラス

KafkaConditions.ConsumerRecordValueCondition <V> - org.springframework.kafka.test.assertj のクラス

kafkaConsumerBackoffManager(ApplicationContext, ListenerContainerRegistry, ObjectProvider<RetryTopicComponentFactory>, RetryTopicSchedulerWrapper, TaskScheduler) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport

パーティションのバックオフに使用される KafkaConsumerBackoffManager インスタンスを作成します。

KafkaConsumerBackoffManager - Interface in org.springframework.kafka.listener

タイムスタンプが未来の場合、指定された dueTimestamp まで MessageListenerContainer をバックオフするためのインターフェース。

KafkaConsumerBackoffManager.Context - org.springframework.kafka.listener のクラス

バックオフに使用される状態を提供します。

KafkaEvent - org.springframework.kafka.event のクラス

イベントの基本クラス。

KafkaEvent(Object, Object) - クラス org.springframework.kafka.event. KafkaEvent のコンストラクター

KafkaException - Exception in org.springframework.kafka

Spring for Apache Kafka 固有の NestedRuntimeException 実装。

KafkaException(String) - Constructor for exception org.springframework.kafka.KafkaException

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

KafkaException(String, Throwable) - Constructor for exception org.springframework.kafka.KafkaException

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

KafkaException(String, KafkaException.Level, Throwable) - Constructor for exception org.springframework.kafka.KafkaException

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

KafkaException.Level - org.springframework.kafka の Enum クラス

KafkaException のログレベル。

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

KafkaException.Level で構成できるクラスのトップレベルの抽象クラス。

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

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

KafkaListener でアノテーションが付けられたクラス内の Kafka メッセージリスナーのターゲットであるメソッドをマークするアノテーション。

KafkaHeaderMapper - Interface in org.springframework.kafka.support

Apache Kafka のヘッダーマッパー。

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

Kafka 固有のメッセージヘッダー定数。

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

KafkaJaasLoginModuleInitializer - org.springframework.kafka.security.jaas のクラス

Kafka クライアントに使用できる AppConfigurationEntrySE を設定するためのプロパティが含まれています。

KafkaJaasLoginModuleInitializer() - クラス org.springframework.kafka.security.jaas. KafkaJaasLoginModuleInitializer のコンストラクター

KafkaJaasLoginModuleInitializer.ControlFlag - org.springframework.kafka.security.jaas の Enum クラス

ログイン構成の制御フラグ値。

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

指定されたトピックで Kafka メッセージリスナーのターゲットとなるメソッドをマークするアノテーション。

KafkaListenerAnnotationBeanPostProcessor< K , V > - Class in org.springframework.kafka.annotation

アノテーションのパラメーターに従って、KafkaListenerContainerFactory によってカバーで作成された Kafka メッセージリスナーコンテナーによって呼び出される、KafkaListener でアノテーションが付けられたメソッドを登録する Bean ポストプロセッサー。

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

KafkaListenerAnnotationBeanPostProcessor.AnnotationEnhancer - org.springframework.kafka.annotation のインターフェース

アノテーション属性の各セットを後処理します。

KafkaListenerConfigurationSelector - org.springframework.kafka.annotation のクラス

可能な限り遅く KafkaBootstrapConfiguration をインポートするための最低次数の DeferredImportSelector 実装。

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

KafkaListenerConfigurer - Interface in org.springframework.kafka.annotation

Spring によって実装されるオプションのインターフェース Bean が Kafka リスナーエンドポイントの構成方法をカスタマイズすることを望んでいます。

KafkaListenerConfigUtils - org.springframework.kafka.config のクラス

サブパッケージ間で内部共有するための構成定数。

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

KafkaListenerContainerFactory< C extends MessageListenerContainer> - Interface in org.springframework.kafka.config

MessageListenerContainer のファクトリ。

KafkaListenerEndpoint - Interface in org.springframework.kafka.config

Kafka リスナーエンドポイントのモデル。

KafkaListenerEndpointRegistrar - org.springframework.kafka.config のクラス

KafkaListenerEndpoint を KafkaListenerEndpointRegistry に登録するためのヘルパー Bean。

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

KafkaListenerEndpointRegistry - org.springframework.kafka.config のクラス

登録されたエンドポイントに必要な MessageListenerContainer インスタンスを作成します。

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

KafkaListenerErrorHandler - Interface in org.springframework.kafka.listener

@KafkaListener メソッドが例外をスローしたときに呼び出されるエラーハンドラー。

KafkaListenerObservation - Enum Class in org.springframework.kafka.support.micrometer

Spring for Apache Kafka リスナーのための観察。

KafkaListenerObservation.DefaultKafkaListenerObservationConvention - org.springframework.kafka.support.micrometer のクラス

Kafka リスナーキー値のデフォルト KafkaListenerObservationConvention。

KafkaListenerObservation.ListenerHighCardinalityTags - org.springframework.kafka.support.micrometer の Enum クラス

高カーディナリティタグ。

KafkaListenerObservation.ListenerLowCardinalityTags - org.springframework.kafka.support.micrometer の Enum クラス

カーディナリティの低いタグ。

KafkaListenerObservationConvention - Interface in org.springframework.kafka.support.micrometer

Kafka リスナーキー値の ObservationConvention。

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

いくつかの KafkaListener アノテーションを集約するコンテナーアノテーション。

KafkaMatchers - org.springframework.kafka.test.hamcrest のクラス

Hamcrest Matcher のユーティリティ。

KafkaMatchers.ConsumerRecordKeyMatcher <K> - org.springframework.kafka.test.hamcrest のクラス

KafkaMatchers.ConsumerRecordPartitionMatcher - org.springframework.kafka.test.hamcrest のクラス

KafkaMatchers.ConsumerRecordTimestampMatcher - org.springframework.kafka.test.hamcrest のクラス

KafkaMatchers.ConsumerRecordValueMatcher <V> - org.springframework.kafka.test.hamcrest のクラス

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

Spring Kafka 要件のための DefaultMessageHandlerMethodFactory の拡張。

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

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

ヘッダーアクセサーは、型固有の方法で特定のヘッダーに簡単にアクセスできるようにします。

KafkaMessageHeaderAccessor(Message<?>) - クラス org.springframework.kafka.support. KafkaMessageHeaderAccessor のコンストラクター

提供されたメッセージのインスタンスを構築します。

KafkaMessageHeaders - org.springframework.kafka.support.converter のクラス

ID ヘッダーとタイムスタンプヘッダーを追加するために構成可能なメッセージヘッダーのオーバーロード。

KafkaMessageListenerContainer< K , V > - Class in org.springframework.kafka.listener

自動パーティション割り当てまたはユーザー構成割り当てをサポートする Java Consumer を使用するシングルスレッドメッセージリスナーコンテナー。

KafkaMessageListenerContainer(ConsumerFactory<? super K, ? super V>, ContainerProperties) - クラス org.springframework.kafka.listener. KafkaMessageListenerContainer のコンストラクター

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

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

このクラスは、NULL Kafka ペイロードを表します。

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

KafkaNull ペイロードを適切にデコードし、null を返す PayloadMethodArgumentResolver。

KafkaOperations< K , V > - Interface in org.springframework.kafka.core

CompletableFutureSE を返す基本的な Kafka オペレーション 契約。

KafkaOperations.OperationsCallback < K , V , T > - Interface in org.springframework.kafka.core

KafkaOperations で任意の操作を実行するためのコールバック。

KafkaOperations.ProducerCallback < K , V , T > - Interface in org.springframework.kafka.core

Producer で任意の操作を実行するためのコールバック。

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

kafka ブローカーがリッスンする明示的なポートを設定します。

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

IMPORTANT: KRaft ベースの EmbeddedKafka を使用する場合、カスタムポートを構成することはできません。

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

kafka ブローカーがリッスンする明示的なポートを設定します。

kafkaPorts(int...) - クラス org.springframework.kafka.test.rule のメソッド。EmbeddedKafkaRule

kafka ブローカーがリッスンする明示的なポートを設定します。

KafkaProducerException - Exception in org.springframework.kafka.core

生産時の例外。

KafkaProducerException(ProducerRecord<?, ?>, String, Throwable) - Constructor for exception org.springframework.kafka.core.KafkaProducerException

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

KafkaRecordReceiverContext - Class in org.springframework.kafka.support.micrometer

 ConsumerRecords の ReceiverContext。

KafkaRecordReceiverContext(ConsumerRecord<?, ?>, String, String, String, Supplier<String>) - Constructor for class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext

Kafka レコードレシーバーコンテキストを構築します。

KafkaRecordReceiverContext(ConsumerRecord<?, ?>, String, Supplier<String>) - Constructor for class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext

Kafka レコードレシーバーコンテキストを構築します。

KafkaRecordSenderContext - Class in org.springframework.kafka.support.micrometer

 ProducerRecords の SenderContext。

KafkaRecordSenderContext(ProducerRecord<?, ?>, String, Supplier<String>) - Constructor for class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext

KafkaReplyTimeoutException - Exception in org.springframework.kafka.requestreply

タイムアウト内に応答が受信されない場合の例外。

KafkaReplyTimeoutException(String) - Constructor for exception org.springframework.kafka.requestreply.KafkaReplyTimeoutException

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

コンシューマー / プロデューサー / 管理者クリエーターの基本クラス。

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

KafkaResourceHolder< K , V > - Class in org.springframework.kafka.core

Kafka リソースホルダー、Kafka プロデューサーをラップします。

KafkaResourceHolder(Producer<K, V>, Duration) - クラス org.springframework.kafka.core. KafkaResourceHolder のコンストラクター

プロデューサーのインスタンスを作成します。

KafkaRuntimeHints - org.springframework.kafka.aot のクラス

Spring for Apache Kafka 用の RuntimeHintsRegistrar。

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

KafkaStreamBrancher< K , V > - Class in org.springframework.kafka.support

Kafka ストリームプロセッサートポロジで branches を構築するためのメソッドチェーン方法を提供します。

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

KafkaStreamsConfiguration - org.springframework.kafka.config のクラス

StreamsBuilder プロパティのラッパー。

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

KafkaStreamsCustomizer - Interface in org.springframework.kafka.config

KafkaStreams を直接構成するために使用できるコールバックインターフェース。

KafkaStreamsDefaultConfiguration - org.springframework.kafka.annotation のクラス

KafkaStreamsDefaultConfiguration.DEFAULT_STREAMS_CONFIG_BEAN_NAME という名前の StreamsConfig がアプリケーションコンテキストに存在する場合、StreamsBuilderFactoryBean を登録する @Configuration クラス。

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

KafkaStreamsInfrastructureCustomizer - Interface in org.springframework.kafka.config

StreamsBuilder や Topology などのインフラストラクチャコンポーネント用のカスタマイザ。

KafkaStreamsInteractiveQueryService - org.springframework.kafka.streams のクラス

Kafka ストリーム内のインタラクティブクエリストアを囲むラッパー API を提供します。

KafkaStreamsInteractiveQueryService(StreamsBuilderFactoryBean) - クラス org.springframework.kafka.streams. KafkaStreamsInteractiveQueryService のコンストラクター

StreamsBuilderFactoryBean 内の KafkaStreams から状態ストアを照会するためのインスタンスを構築します。

KafkaStreamsMicrometerListener - org.springframework.kafka.streams のクラス

KafkaStreams の KafkaStreamsMetrics を作成します。

KafkaStreamsMicrometerListener(MeterRegistry) - クラス org.springframework.kafka.streams. KafkaStreamsMicrometerListener のコンストラクター

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

KafkaStreamsMicrometerListener(MeterRegistry, List<Tag>) - クラス org.springframework.kafka.streams. KafkaStreamsMicrometerListener のコンストラクター

提供されたレジストリとタグを使用してインスタンスを構築します。

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

メッセージを再試行トピックと Dlt トピックに転送するために使用される KafkaTemplate Bean の Bean 名。

KafkaTemplate< K , V > - Class in org.springframework.kafka.core

高レベルの操作を実行するためのテンプレート。

KafkaTemplate(ProducerFactory<K, V>) - クラス org.springframework.kafka.core. KafkaTemplate のコンストラクター

提供されたプロデューサーファクトリと autoFlush false を使用してインスタンスを作成します。

KafkaTemplate(ProducerFactory<K, V>, boolean) - クラス org.springframework.kafka.core. KafkaTemplate のコンストラクター

提供されたプロデューサーファクトリと autoFlush 設定を使用してインスタンスを作成します。

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

提供されたプロデューサーファクトリと autoFlush 設定を使用してインスタンスを作成します。

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

autoFlush を false にして、提供されたプロデューサーファクトリとプロパティを使用してインスタンスを作成します。

KafkaTemplateObservation - Enum Class in org.springframework.kafka.support.micrometer

Spring for Apache Kafka KafkaTemplate の観測。

KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention - org.springframework.kafka.support.micrometer のクラス

Kafka テンプレートキー値のデフォルト KafkaTemplateObservationConvention。

KafkaTemplateObservation.TemplateLowCardinalityTags - org.springframework.kafka.support.micrometer の Enum クラス

カーディナリティの低いタグ。

KafkaTemplateObservationConvention - Interface in org.springframework.kafka.support.micrometer

Kafka テンプレートキー値の ObservationConvention。

KafkaTestUtils - org.springframework.kafka.test.utils のクラス

Kafka テストユーティリティ。

KafkaTransactionManager< K , V > - Class in org.springframework.kafka.transaction

単一の Kafka ProducerFactory の PlatformTransactionManager 実装。

KafkaTransactionManager(ProducerFactory<K, V>) - クラス org.springframework.kafka.transaction. KafkaTransactionManager のコンストラクター

ProducerFactory を指定して、新しい KafkaTransactionManager を作成します。

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

ユーティリティメソッド。

key(K) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

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

Kafka にデータを送信する際のレコードキーを含むヘッダー。

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

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

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

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

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

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

KEY_DEFAULT_TYPE - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

ヘッダーがない場合のデフォルトのキー型の Kafka 構成プロパティ。

KEY_DESERIALIZER_CLASS - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer

デリゲートキーデシリアライザーのプロパティ名。

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

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

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

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

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

キー逆直列化例外を使用して別のトピックに送信された、公開されたレコードの例外クラス名。

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

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

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

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

KEY_FUNCTION - Static variable in class org.springframework.kafka.support.serializer.ErrorHandlingDeserializer

デシリアライズが失敗したときの T のサプライヤー。

KEY_PARSER - Static variable in class org.springframework.kafka.support.serializer.ParseStringDeserializer

キーパーサーメソッドのプロパティ。

KEY_SERIALIZATION_SELECTOR - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer

キーの直列化セレクターを含むヘッダーの名前。

KEY_SERIALIZATION_SELECTOR_CONFIG - Static variable in class org.springframework.kafka.support.serializer.DelegatingSerializer

selector:class,... 形式のキーの直列化セレクターマップを含む構成プロパティの名前。

KEY_SERIALIZATION_TOPIC_CONFIG - Static variable in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization

pattern:class,... 形式のキーの直列化トピックパターンマップを含む構成プロパティの名前。

KEY_SERIALIZATION_TOPIC_DEFAULT - Static variable in class org.springframework.kafka.support.serializer.DelegatingByTopicSerialization

トピック名が一致しない場合のキーのデフォルトのデリゲートの名前。

KEY_TYPE - Static variable in class org.springframework.kafka.support.serializer.ToStringSerializer

キーの型のヘッダー。

KEY_TYPE_METHOD - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

キーを逆直列化する JavaType を決定するメソッド名: 'com.Foo.deserialize'。

keyDeserializer(boolean) - クラス org.springframework.kafka.support.serializer のメソッド。ErrorHandlingDeserializer

Kafka の外部で構成するときに、このデシリアライザーをキーデシリアライザーとして使用する場合は true に設定します。

keyExceptionFqcn(String) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo

元のレコードの keyExceptionFqcn を格納するために使用されるヘッダーの名前を設定します。

keyExceptionMessage(String) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo

元のレコードの keyExceptionMessage を格納するために使用されるヘッダーの名前を設定します。

keyExceptionStacktrace(String) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Builder.ExceptionInfo

元のレコードの keyExceptionStacktrace を格納するために使用されるヘッダーの名前を設定します。

keyValue(K, V) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

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

Kotlin suspend 機能をサポートするための InvocableHandlerMethod 拡張。

KotlinAwareInvocableHandlerMethod(Object, Method) - クラス org.springframework.kafka.listener.adapter. KotlinAwareInvocableHandlerMethod のコンストラクター

kraft() - Element in annotation interface org.springframework.kafka.test.context.EmbeddedKafka

Zookeeper の代わりに KRaft を使用します。デフォルトは false です。

KRAFT_PROPERTY_NAME - Static variable in class org.springframework.kafka.test.junit.GlobalEmbeddedKafkaTestExecutionListener

埋め込みブローカーで作成するトピックのパーティションの数。

KSTREAM_DESERIALIZATION_RECOVERER - Static variable in class org.springframework.kafka.streams.RecoveringDeserializationExceptionHandler

プロパティを使用して回復者を構成するためのプロパティ名。