インデックス

E

EmbeddedKafka - Annotation Interface in org.springframework.kafka.test.context

Spring for Apache Kafka ベースのテストを実行するテストクラスで指定できるアノテーション。

EmbeddedKafkaBroker - Interface in org.springframework.kafka.test

EmbeddedKafkaBrokerFactory - org.springframework.kafka.test のクラス

EmbeddedKafkaBroker 作成ロジックをカプセル化するファクトリ。

EmbeddedKafkaCondition - org.springframework.kafka.test.condition のクラス

組み込みブローカーの JUnit5 条件。

EmbeddedKafkaCondition() - クラス org.springframework.kafka.test.condition. EmbeddedKafkaCondition のコンストラクター

EmbeddedKafkaKraftBroker - org.springframework.kafka.test のクラス

KRaft を使用した組み込み Kafka ブローカー。

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

ランダムポートでリッスンする組み込み Kafka ブローカーを作成します。

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

AbstractKafkaListenerContainerFactory によってカバーで作成された Kafka リスナーのアノテーション付きエンドポイントを有効にします。

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

ノンブロッキングトピックベースの遅延再試行機能を有効にします。

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

デフォルトの Kafka Streams コンポーネントを有効にします。

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

最後まで探してください。

EndpointCustomizer< T extends MethodKafkaListenerEndpoint<?,?>> - Interface in org.springframework.kafka.retrytopic

トピックの再試行機能でメイン、再試行、DLT エンドポイントをカスタマイズし、結果のトピック名を返します。

EndpointCustomizer.TopicNamesHolder - org.springframework.kafka.retrytopic の記録クラス

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

RetryTopicConfigurer がメインエンドポイント、再試行エンドポイント、DLT エンドポイントをカスタマイズするために使用する EndpointCustomizer を作成します。

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

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

エンドポイントを再試行するためのハンドラーメソッド。

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

提供された Bean のインスタンスを構築します。

EndpointHandlerMethod(Object, Method) - クラス org.springframework.kafka.support. EndpointHandlerMethod のコンストラクター

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

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

エンドポイントを再試行するためのハンドラーマルチメソッド。

EndpointHandlerMultiMethod(Object, Method, List<Method>) - クラス org.springframework.kafka.support. EndpointHandlerMultiMethod のコンストラクター

提供された Bean、defaultMethod、メソッドのインスタンスを構築します。

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

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

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

強制的なリバランスをトリガーするようにコンシューマーに警告します。

enforceRebalanceRequested - Variable in class org.springframework.kafka.listener.AbstractMessageListenerContainer

enhancedJsonMapper() - Static method in class org.springframework.kafka.support.JacksonMapperUtils

既知のモジュールが登録され、MapperFeature.DEFAULT_VIEW_INCLUSION および DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES 機能が無効になっている ObjectMapper インスタンスのファクトリ。

enhancedObjectMapper() - Static method in class org.springframework.kafka.support.JacksonUtils

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

既知のモジュールが登録され、MapperFeature.DEFAULT_VIEW_INCLUSION および DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES 機能が無効になっている ObjectMapper インスタンスのファクトリ。

enrichHeadersAndCreateProducerRecord(ConsumerRecord<byte[], byte[]>, Exception, TopicPartition) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

ヘッダーに逆直列化例外情報とメタデータを追加し、デッドレターパブリッシング用のプロデューサーレコードを作成します。

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

equals(Object) - Method in record class org.springframework.kafka.listener.adapter.InvocationResult

他のオブジェクトがこのオブジェクトと「等しい」かどうかを示します。

equals(Object) - レコードクラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter.ReplyExpressionRoot

他のオブジェクトがこのオブジェクトと「等しい」かどうかを示します。

equals(Object) - クラス org.springframework.kafka.requestreply のメソッド。CorrelationKey

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

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

equals(Object) - レコードクラス org.springframework.kafka.retrytopic のメソッド。EndpointCustomizer.TopicNamesHolder

他のオブジェクトがこのオブジェクトと「等しい」かどうかを示します。

equals(Object) - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset

equals(Object) - クラス org.springframework.kafka.test.core のメソッド。BrokerAddress

ERROR - Enum constant in enum class org.springframework.kafka.event.ConsumerStoppedEvent.Reason

ErrorSE が投げられました。

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

エラー。

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

エラー。

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

リスナーメソッドが例外をスローした場合に呼び出す KafkaListenerErrorHandler Bean 名を設定します。

ErrorHandlingDeserializer< T > - Class in org.springframework.kafka.support.serializer

例外をキャッチするデリゲートキー / 値デシリアライザは、直列化された java オブジェクトとしてヘッダーに返します。

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

ErrorHandlingDeserializer(Deserializer<T>) - クラス org.springframework.kafka.support.serializer. ErrorHandlingDeserializer のコンストラクター

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

エラー処理のためのユーティリティ。

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

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

EX_CAUSE - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

例外原因クラス名。

EX_MSG - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

例外メッセージ。

EX_STACKTRACE - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

例外スタックトレース。

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

例外ビルダーを返します。

EXCEPTION - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

例外クラス名。

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

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

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

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

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

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

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

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

ExceptionBasedDltDestination - Annotation Interface in org.springframework.kafka.retrytopic

メッセージ処理によって構成された例外がスローされたときに選択される追加の DLT を指定できるようにするアノテーション。

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

処理中にスローされた例外に基づいてメッセージをカスタム DLT にリダイレクトできるようにする DLT ルーティング。

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

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

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

例外分類をサポートします。

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

インスタンスを構築します。

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

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

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

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

ネストされた原因内の一致する例外を識別するためのサポートを備えた、構成可能な例外マッチャー。

ExceptionMatcher(Collection<Class<? extends Throwable>>, boolean) - クラス org.springframework.kafka.support. ExceptionMatcher のコンストラクター

例外のリストを含むインスタンスを作成します。

ExceptionMatcher(Map<Class<? extends Throwable>, Boolean>, boolean, boolean) - クラス org.springframework.kafka.support. ExceptionMatcher のコンストラクター

ExceptionMatcher.Builder - org.springframework.kafka.support のクラス

ExceptionMatcher を構成するための Fluent API。

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

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

exceptions() - Element in annotation interface org.springframework.kafka.retrytopic.ExceptionBasedDltDestination

メッセージ処理で、ここで構成された例外のいずれかがスローされた場合、最終的には、ExceptionBasedDltDestination.suffix() を通じて構成された拡張子を含む名前を持つ DLT にリダイレクトされる必要があります。

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

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

exchange(Message<?>) - インターフェース org.springframework.kafka.streams.messaging のメソッド。MessagingFunction

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

再試行してはならない例外型。

excludeHeader(DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd...) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

ヘッダー名のヘッダー包含ビットをクリアします。

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

再試行してはならない例外クラス名。

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

ターゲット構成が使用されないトピック名を構成します。

excludeTopics(List<String>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

ターゲット構成が使用されないトピック名を構成します。

execute(KafkaOperations.ProducerCallback<Object, Object, T>) - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate

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

プロデューサーで任意の操作を実行し、結果を返します。

execute(KafkaOperations.ProducerCallback<K, V, T>) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

executeInTransaction(KafkaOperations.OperationsCallback<Object, Object, T>) - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate

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

操作に対して任意の操作を実行し、結果を返します。

executeInTransaction(KafkaOperations.OperationsCallback<K, V, T>) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

EXPLICIT - Enum constant in enum class org.springframework.kafka.listener.ContainerProperties.ShareAckMode

Kafka クライアント明示モード、コンテナー管理。

exponentialBackoff(long, double, long) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

ExponentialBackOff を構成します。

exponentialBackoff(long, double, long, long) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

ジッター値を使用して ExponentialBackOff を設定します。

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

最大経過時間ではなく最大再試行回数を指定できる ExponentialBackOff のサブクラス。

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

maxRetries から ExponentialBackOffWithMaxRetries.setMaxElapsedTime(long) を計算するインスタンスを構築します。

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

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

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。JacksonJsonMessageConverter

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。JacksonProjectingMessageConverter

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。JsonMessageConverter

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

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

サブクラスは値を変換できます。デフォルトでは、変換できる SmartMessageConverter がない限り、Kafka によって提供されるものとして返されます。

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。ProjectingMessageConverter

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

extractAndConvertValue(ConsumerRecord<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

サブクラスは値を変換できます。デフォルトでは、RecordMessageConverter が提供されていない限り、Kafka によって提供されたとおりに返されます。