インデックス

B

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

この操作を再試行するためのバックオフプロパティを指定します。

backOff(BackOff) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport.BlockingRetriesConfigurer

ブロッキング再試行メカニズムで使用する必要がある BackOff を設定します。

BackOffHandler - Interface in org.springframework.kafka.listener

指定されたバックオフ時間、リスナーコンテナー、例外のハンドラー。

backOffIfNecessary(KafkaConsumerBackoffManager.Context) - クラス org.springframework.kafka.listener のメソッド。ContainerPartitionPausingBackOffManager

現在の時刻が KafkaConsumerBackoffManager.Context オブジェクトで提供される dueTimestamp より前の場合はバックオフします。

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

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

指定された maxAttempts 値と BackOffPolicy からバックオフ値を生成します。

BackOffValuesGenerator(int, BackOffPolicy) - クラス org.springframework.kafka.retrytopic. BackOffValuesGenerator のコンストラクター

batch() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener

コンテナーファクトリの batchListener プロパティをオーバーライドします。

BATCH - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.AckMode

すべてのレコードがリスナーによって処理された後、前のポーリングによって返されたすべてのレコードのオフセットをコミットします。

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

変換されたネイティブ Kafka ヘッダーのマップのリストのヘッダー。

BatchAcknowledgingConsumerAwareMessageListener< K , V > - Interface in org.springframework.kafka.listener

受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。

BatchAcknowledgingMessageListener< K , V > - Interface in org.springframework.kafka.listener

受信 Kafka メッセージのバッチを処理するためのリスナーであり、メッセージが処理されたときに受信者が呼び出すことができる確認ハンドルを伝達します。

BatchConsumerAwareMessageListener< K , V > - Interface in org.springframework.kafka.listener

受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。

BatchInterceptor< K , V > - Interface in org.springframework.kafka.listener

レコードのバッチのインターセプター。

BatchListenerFailedException - Exception in org.springframework.kafka.listener

バッチ内のどのレコードが失敗したかをフレームワークに通知するために、ユーザーコードによってスローされる例外。

BatchListenerFailedException(String, int) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

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

BatchListenerFailedException(String, Throwable, int) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

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

BatchListenerFailedException(String, Throwable, ConsumerRecord<?, ?>) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

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

BatchListenerFailedException(String, ConsumerRecord<?, ?>) - Constructor for exception org.springframework.kafka.listener.BatchListenerFailedException

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

BatchMessageConverter - Interface in org.springframework.kafka.support.converter

Kafka 固有の Message コンバーター戦略。

BatchMessageListener< K , V > - Interface in org.springframework.kafka.listener

受信 Kafka メッセージのバッチを処理するためのリスナー。リストは、ポーリングによって返されるコンシューマーレコードオブジェクトから作成されます。

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

バッチメッセージリスナーで使用されるメッセージング MessageConverter 実装。コンシューマーレコードの値は、メッセージペイロードのコレクションに抽出されます。

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

レコード値を変換しないインスタンスを作成します。

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

提供されたコンバーターを使用してレコード値を変換するインスタンスを作成します。

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

構成可能な HandlerAdapter を呼び出す MessageListener アダプター。リスナーがメッセージのバッチを受信するようにファクトリが構成されている場合に使用されます。

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

指定されたパラメーターを使用してインスタンスを作成します。

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

指定されたパラメーターを使用してインスタンスを作成します。

BatchToRecordAdapter< K , V > - Interface in org.springframework.kafka.listener.adapter

バッチリスナーをレコードリスナーメソッドに適合させるアダプター。

BatchToRecordAdapter.Callback < K , V > - Interface in org.springframework.kafka.listener.adapter

各メッセージのコールバック。

BEAN_NAME - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation.TemplateLowCardinalityTags

テンプレートの Bean 名。

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

beanRef() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener

このアノテーション内の SpEL 式で使用される疑似 Bean 名は、このリスナーが定義されている現在の Bean を参照します。

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

beforeAll(ExtensionContext) - クラス org.springframework.kafka.test.condition のメソッド。LogLevelsCondition

beforeEach(ExtensionContext) - クラス org.springframework.kafka.test.condition のメソッド。LogLevelsCondition

BEGINNING - Enum constant in enum class org.springframework.kafka.support.TopicPartitionOffset.SeekPosition

最初に探します。

beginningOffsets(TopicPartition...) - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaConsumerTemplate

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

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

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

ブートストラップサーバーアドレスおよびデフォルトの "spring.embedded.kafka.brokers" で設定するプロパティ名。

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

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

新しいブランチを定義します。

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

このプロパティの値を、"spring.embedded.kafka.brokers" の代わりに埋め込みブローカーアドレスのリストに設定する必要があるプロパティ名に設定します。

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

このプロパティの値を、"spring.embedded.kafka.brokers" の代わりに埋め込みブローカーアドレスのリストに設定する必要があるプロパティ名に設定します。

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

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

Kafka ブローカー構成のプロパティファイルの場所。

BrokerAddress - org.springframework.kafka.test.core のクラス

Kafka ブローカーのアドレスをカプセル化します。

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

BrokerAddress(String, int) - クラス org.springframework.kafka.test.core. BrokerAddress のコンストラクター

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

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

この名前のシステムプロパティをブローカーアドレスのリストに設定します。

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

この名前のシステムプロパティをブローカーアドレスのリストに設定します。

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

この名前のシステムプロパティをブローカーアドレスのリストに設定します。

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

実行前にブローカー構成に追加する必要がある形式 key = value のプロパティ。

brokerProperties(Map<String, String>) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

開始前に Kafka ブローカーを構成するためのプロパティを指定します。

brokerProperties(Map<String, String>) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

開始前に Kafka ブローカーを構成するためのプロパティを指定します。

brokerProperties(Map<String, String>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

開始前に Kafka ブローカーを構成するためのプロパティを指定します。

brokerProperties(Map<String, String>) - クラス org.springframework.kafka.test.rule のメソッド。EmbeddedKafkaRule

開始前に Kafka ブローカーを構成するためのプロパティを指定します。

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

Spring Resource url は、ブローカー構成に追加する必要があるプロパティの場所を指定します。

brokerProperty(String, Object) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

ブローカープロパティを指定します。

brokerProperty(String, Object) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

ブローカープロパティを指定します。

brokerProperty(String, Object) - クラス org.springframework.kafka.test.rule のメソッド。EmbeddedKafkaRule

ブローカープロパティを指定します。

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

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

ヘッダー名を作成し、いずれも null ではないことを表明します。

build(Map<String, ?>, boolean, String, Object, Pattern) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

buildConsumerRecordMetadata(Object) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

ConsumerRecord でなければならないデータから ConsumerRecordMetadata を構築します。

buildConsumerRecordMetadataFromArray(Object...) - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils

データ内の最初の ConsumerRecord から ConsumerRecordMetadata を構築します (存在する場合)。

buildDefault(Map<String, ?>, String, boolean, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

Builder() - クラス org.springframework.kafka.listener のコンストラクター。DeadLetterPublishingRecoverer.HeaderNames.Builder

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

JSON メッセージコンバーター - 出力の場合は byte[]、入力の場合は String、Bytes、byte[]。

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

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

byteArrayToDeserializationException(LogAccessor, Header) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils

直列化された DeserializationException を含むバイト配列を DeserializationException に変換します。

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

JSON メッセージコンバーター - 出力の場合は Bytes、入力の場合は String、Bytes、byte[]。

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

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