インデックス

B

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

この操作を再試行するための backOff プロパティを指定します。

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

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

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

RetryPolicy の一部として 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 値と BackOff からバックオフ値を生成します。

BackOffValuesGenerator(int, BackOff) - クラス 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> - org.springframework.kafka.listener のインターフェース

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

バッチ承認メッセージリスナー <K, V> - org.springframework.kafka.listener のインターフェース

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

BatchConsumerAwareMessageListener<K, V> - org.springframework.kafka.listener のインターフェース

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

バッチインターセプター <K, V> - org.springframework.kafka.listener のインターフェース

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

BatchListenerFailedException - Exception Class in org.springframework.kafka.listener

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

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

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

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

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

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

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

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

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

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

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

バッチメッセージリスナー <K, V> - org.springframework.kafka.listener のインターフェース

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

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

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

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

レコード変換用にデフォルトの MessagingMessageConverter を持つインスタンスを作成します。

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

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

バッチメッセージングメッセージリスナーアダプター <K, V> - 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 のコンストラクター

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

バッチレコードアダプター <K, V> - org.springframework.kafka.listener.adapter のインターフェース

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

BatchToRecordAdapter. コールバック <K, V> - 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 を参照します。

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

最初に探します。

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

bindClient(String, C) - クラス org.springframework.kafka.core のメソッド。KafkaMetricsSupport

指定された ID を使用して Apache Kafka クライアントのメトリクスをバインドします。

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

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

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

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

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

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 ブローカーを構成するためのプロパティを指定します。

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

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

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

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

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

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

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

build() - クラス org.springframework.kafka.support のメソッド。ExceptionMatcher.Builder

ExceptionMatcher を構築します。

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

Builder(boolean) - クラス org.springframework.kafka.support のコンストラクター。ExceptionMatcher.Builder

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

出力に Jackson 3 - byte[]、入力に文字列、バイト、byte[] を使用する JSON メッセージコンバーター。

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

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

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

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

4.0 以降、Jackson 3 では ByteArrayJacksonJsonMessageConverter が優先されます。

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 に変換します。

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

出力に Bytes、入力に文字列、バイト、byte[] を使用する JSON メッセージコンバーター。

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

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

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

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

4.0 以降、Jackson 3 では BytesJacksonJsonMessageConverter が優先されます。

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

使用すべきではありません。

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

使用すべきではありません。