インデックス

E

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

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

EmbeddedKafkaBroker - Interface in org.springframework.kafka.test

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 ブローカーを作成します。

EmbeddedKafkaRule - org.springframework.kafka.test.rule のクラス

EmbeddedKafkaBroker の周囲の TestRule ラッパー。

EmbeddedKafkaRule(int) - クラス org.springframework.kafka.test.rule. EmbeddedKafkaRule のコンストラクター

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

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

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

組み込みの Kafka ブローカーを作成します。

EmbeddedKafkaZKBroker - Class in org.springframework.kafka.test

組み込みの Kafka ブローカーおよび Zookeeper マネージャー。

EmbeddedKafkaZKBroker(int) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker

EmbeddedKafkaZKBroker(int, boolean, int, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker

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

EmbeddedKafkaZKBroker(int, boolean, String...) - Constructor for class org.springframework.kafka.test.EmbeddedKafkaZKBroker

組み込みの Kafka ブローカーを作成します。

EmbeddedKafkaZKBroker.EmbeddedZookeeper - org.springframework.kafka.test のクラス

ポートを設定できるように scala から移植しました。

EmbeddedZookeeper(int) - クラス org.springframework.kafka.test のコンストラクター。EmbeddedKafkaZKBroker.EmbeddedZookeeper

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

AbstractListenerContainerFactory によってカバーで作成された 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

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

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

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

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

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

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

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

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

equals(Object) - Method in record class 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.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

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

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

ExponentialBackOffPolicy を構成します。

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

ランダムパラメーターに応じて、ExponentialBackOffPolicy または ExponentialRandomBackOffPolicy を設定します。

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

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

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

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