インデックス

C

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

false に設定すると、トピックパターンマッチングで大文字と小文字が区別されなくなります。

categories() - Element in annotation interface org.springframework.kafka.test.condition.LogLevels

変更する Log4j または Logback カテゴリを表すカテゴリ名。

categories(String...) - クラス org.springframework.kafka.test.rule のメソッド。Log4j2LevelAdjuster

連鎖 Kafka トランザクションマネージャー <K, V> - org.springframework.kafka.transaction のクラス

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

ChainedTransactionManager javadoc を参照してください。

ChainedKafkaTransactionManager(PlatformTransactionManager...) - クラス org.springframework.kafka.transaction. ChainedKafkaTransactionManager のコンストラクター

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

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

checkBootstrap(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。KafkaResourceFactory

KafkaResourceFactory.setBootstrapServersSupplier(Supplier) を呼び出してプロパティを拡張し、ブートストラップサーバーのプロパティを置き換えます。

checkDeserialization(ConsumerRecord<?, ?>, LogAccessor) - Static method in class org.springframework.kafka.requestreply.ReplyingKafkaTemplate

キーまたは値のいずれかが逆直列化に失敗した場合は DeserializationException を返します。それ以外の場合は null。

checkDeserializer(ConsumerFactory<K, V>, Properties, boolean, ClassLoader) - Static method in class org.springframework.kafka.listener.ErrorHandlingUtils

キーまたは値のデシリアライザーが ErrorHandlingDeserializer のインスタンスであるかどうかを判断します。

checkForErrors(ConsumerRecord<K, R>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

返信にエラーがないか確認してください。

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

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

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

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

子コンテナーが起動したことを親コンテナーに通知します。

childStopped(MessageListenerContainer, ConsumerStoppedEvent.Reason) - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer

childStopped(MessageListenerContainer, ConsumerStoppedEvent.Reason) - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer

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

子コンテナーが停止したことを親コンテナーに通知します。

classes() - Element in annotation interface org.springframework.kafka.test.condition.LogLevels

変更する Log4j カテゴリを表すクラス。

ClassMapper - Interface in org.springframework.kafka.support.mapping

メッセージの受信時にインスタンス化する必要があるクラスを作成できるように、メッセージにメタデータを設定するための戦略。

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

KafkaStreams.cleanUp() の実行時刻を指定します。

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

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

cleanupOnStart() - クラス org.springframework.kafka.core のメソッド。CleanupConfig

cleanupOnStop() - クラス org.springframework.kafka.core のメソッド。CleanupConfig

clearConsumerGroupId() - Static method in class org.springframework.kafka.support.KafkaUtils

このスレッドにバインドされているコンシューマーのグループ ID をクリアします。

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

スレッド状態をクリアするオプションのメソッド。コンシューマースレッドが終了する直前に呼び出されます。

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

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

スレッド状態をクリアするオプションのメソッド。コンシューマースレッドが終了する直前に呼び出されます。

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

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

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

clearThreadState(Consumer<?, ?>) - クラス org.springframework.kafka.listener のメソッド。CompositeBatchInterceptor

clearThreadState(Consumer<?, ?>) - クラス org.springframework.kafka.listener のメソッド。CompositeRecordInterceptor

clearThreadState(Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。ThreadStateProcessor

ThreadStateProcessor.setupThreadState(Consumer) で設定されたスレッドにバインドされたリソースをクリアするために呼び出します。

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

提供されると、コンシューマーファクトリ構成のクライアント ID プロパティをオーバーライドします。

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

close() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory.ExtendedKafkaConsumer

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

close() - クラス org.springframework.kafka.core のメソッド。KafkaResourceHolder

close() - クラス org.springframework.kafka.core.reactive のメソッド。ReactiveKafkaProducerTemplate

close() - クラス org.springframework.kafka.streams のメソッド。HeaderEnricherProcessor

close() - クラス org.springframework.kafka.streams.messaging のメソッド。MessagingProcessor

close() - クラス org.springframework.kafka.support のメソッド。CompositeProducerInterceptor

close() - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerialization

close() - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingDeserializer

close() - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingSerializer

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

close() - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

close() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

close() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

close() - クラス org.springframework.kafka.support.serializer のメソッド。RetryingDeserializer

close() - クラス org.springframework.kafka.support.serializer のメソッド。StringOrBytesSerializer

close() - クラス org.springframework.kafka.support.serializer のメソッド。ToStringSerializer

close(Duration) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory.ExtendedKafkaConsumer

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

closeProducer(Producer<K, V>, boolean) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

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

DefaultKafkaProducerFactory.setProducerPerThread(boolean) (true) を使用する場合、このメソッドを呼び出して、このスレッドのプロデューサーを閉じて解放します。

closeThreadBoundProducer() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

ファクトリ実装でスレッドにバインドされたプロデューサーを使用する場合は、このメソッドを呼び出して、このスレッドのプロデューサーを閉じて解放します。

clusterId() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin

clusterId() - インターフェース org.springframework.kafka.core のメソッド。KafkaAdminOperations

利用可能な場合は、クラスター ID を返します。

clusterId() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

利用可能な場合は、クラスター ID を返します。

commit() - クラス org.springframework.kafka.core のメソッド。KafkaResourceHolder

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

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

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

エラーが発生したときにコンテナーを停止する CommonErrorHandler。

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

デフォルトの SimpleAsyncTaskExecutor を使用してインスタンスを作成します。

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

提供された ExecutorSE を使用してインスタンスを構築します。

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

例外の種類に応じて、さまざまなエラーハンドラーに委譲するエラーハンドラー。

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

例外に一致するものがない場合に呼び出されるデフォルトのエラーハンドラーを使用してインスタンスを構築します。

CommonErrorHandler - Interface in org.springframework.kafka.listener

リスナーコンテナーのエラー処理契約。

commonHeaders(Acknowledgment, Consumer<?, ?>, Map<String, Object>, Object, Object, Object, Object, Object, Object) - インターフェース org.springframework.kafka.support.converter のメソッド。MessageConverter

共通ヘッダーを設定します。

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

例外をログに記録するための CommonErrorHandler 実装。

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

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

レコードリスナーとバッチリスナーの異なる CommonErrorHandler に委譲する CommonErrorHandler。

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

提供されたデリゲート CommonErrorHandler を使用してインスタンスを構築します。

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

TopicConfig.CLEANUP_POLICY_CONFIG を TopicConfig.CLEANUP_POLICY_COMPACT に設定します。

複合バッチインターセプター <K, V> - org.springframework.kafka.listener のクラス

1 つ以上の BatchInterceptor に順番に委譲する BatchInterceptor。

CompositeBatchInterceptor(BatchInterceptor<K, V>...) - クラス org.springframework.kafka.listener. CompositeBatchInterceptor のコンストラクター

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

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

コンポジット KafkaStreamsCustomizer は、提供された KafkaStreamsCustomizer のリストに委譲することにより、KafkaStreams をカスタマイズします。

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

CompositeKafkaStreamsCustomizer(List<KafkaStreamsCustomizer>) - クラス org.springframework.kafka.config. CompositeKafkaStreamsCustomizer のコンストラクター

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

コンポジット KafkaStreamsInfrastructureCustomizer は、提供された KafkaStreamsInfrastructureCustomizer のリストに委譲することにより、KafkaStreams をカスタマイズします。

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

提供されているカスタマイザーを使用してインスタンスを構築します。

複合プロデューサーインターセプター <K, V> - org.springframework.kafka.support のクラス

インターセプターのコレクションに委譲する ProducerInterceptor。

CompositeProducerInterceptor(ProducerInterceptor<K, V>...) - クラス org.springframework.kafka.support. CompositeProducerInterceptor のコンストラクター

提供された ProducerInterceptor へのデリゲートを使用してインスタンスを構築します。

複合プロデューサーリスナー <K, V> - org.springframework.kafka.support のクラス

リスナーのコレクションに委譲する ProducerListener。

CompositeProducerListener(ProducerListener<K, V>...) - クラス org.springframework.kafka.support. CompositeProducerListener のコンストラクター

複合レコードインターセプター <K, V> - org.springframework.kafka.listener のクラス

1 つ以上の RecordInterceptor に順番に委譲する RecordInterceptor。

CompositeRecordInterceptor(RecordInterceptor<K, V>...) - クラス org.springframework.kafka.listener. CompositeRecordInterceptor のコンストラクター

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

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

このリスナーのコンテナーファクトリの concurrency 設定を上書きします。

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

再試行コンテナーと DLT コンテナーの同時実行。指定しない場合、メインコンテナーの同時実行性が使用されます。

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

再試行コンテナーと DLT コンテナーの同時実行を構成します。

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

同時実行コンテナーが停止されたときに発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

ConcurrentKafkaListenerContainerFactory<K, V> - org.springframework.kafka.config のクラス

ConcurrentMessageListenerContainer を構築するための KafkaListenerContainerFactory 実装。

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

同時メッセージリスナーコンテナー <K, V> - org.springframework.kafka.listener のクラス

concurrency に基づいて 1 つ以上の KafkaMessageListenerContainer を作成します。

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

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

conditionalSleep(Supplier<Boolean>, long) - Static method in class org.springframework.kafka.listener.ListenerUtils

shouldSleepCondition が true を供給する限り、希望するタイムアウトの間スリープします。

conditionalSleepWithPoll(Supplier<Boolean>, long, Consumer<?, ?>) - Static method in class org.springframework.kafka.listener.ListenerUtils

shouldSleepCondition が true を供給する限り、希望するタイムアウトの間スリープします。

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

構成オプションを設定します。

configs(Map<String, String>) - クラス org.springframework.kafka.config のメソッド。TopicBuilder

構成を設定します。

configure(C) - インターフェース org.springframework.kafka.config のメソッド。ContainerCustomizer

コンテナーを構成します。

configure(Map<String, ?>) - クラス org.springframework.kafka.streams のメソッド。RecoveringDeserializationExceptionHandler

configure(Map<String, ?>) - クラス org.springframework.kafka.support のメソッド。CompositeProducerInterceptor

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

configure(StreamsBuilderFactoryBean) - インターフェース org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBeanConfigurer

ファクトリ Bean を構成します。

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

このメソッドをオーバーライドして、再試行する例外や使用する BackOff などのブロック再試行パラメーターを構成します。

configureBuilder(StreamsBuilder) - クラス org.springframework.kafka.config のメソッド。CompositeKafkaStreamsInfrastructureCustomizer

configureBuilder(StreamsBuilder) - インターフェース org.springframework.kafka.config のメソッド。KafkaStreamsInfrastructureCustomizer

ビルダーを構成します。

configureCustomizers(RetryTopicConfigurationSupport.CustomizersConfigurer) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport

このメソッドをオーバーライドして、MessageListenerContainer、DeadLetterPublishingRecoverer、DefaultErrorHandler などのノンブロッキング再試行の構成によって作成されたコンポーネントのカスタマイザーを構成します。

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

DeadLetterPublishingRecovererFactory をさらに構成するには、このメソッドをオーバーライドします。

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

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

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

デリゲートを構成します。

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

このメソッドをオーバーライドして、DestinationTopicResolver を構成します。

configureKafkaListeners(KafkaListenerEndpointRegistrar) - インターフェース org.springframework.kafka.annotation のメソッド。KafkaListenerConfigurer

KafkaListenerEndpointRegistry および特定の KafkaListenerEndpoint インスタンスを特定の KafkaListenerEndpointRegistrar に対して登録できるようにするコールバック。

configureListenerAdapter(MessagingMessageListenerAdapter<K, V>) - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint

このリスナーアダプターの HandlerAdapter を作成します。

configureListenerAdapter(MessagingMessageListenerAdapter<K, V>) - クラス org.springframework.kafka.config のメソッド。MultiMethodKafkaListenerEndpoint

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

ListenerContainerFactoryConfigurer をさらに構成するには、このメソッドをオーバーライドします。

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

RetryTopicConfigurer を構成する必要がある場合は、このメソッドをオーバーライドします。

configureTopology(Topology) - クラス org.springframework.kafka.config のメソッド。CompositeKafkaStreamsInfrastructureCustomizer

configureTopology(Topology) - インターフェース org.springframework.kafka.config のメソッド。KafkaStreamsInfrastructureCustomizer

トポロジを構成します。

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

すべての埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromAllEmbeddedTopics(Consumer<?, ?>) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

すべての埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromAllEmbeddedTopics(Consumer<?, ?>) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

すべての埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromAllEmbeddedTopics(Consumer<?, ?>, boolean) - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker

すべての埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromAllEmbeddedTopics(Consumer<?, ?>, boolean) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

すべての埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromAllEmbeddedTopics(Consumer<?, ?>, boolean) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

すべての埋め込みトピックにコンシューマーをサブスクライブします。

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

埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

consumeFromAnEmbeddedTopic(Consumer<?, ?>, boolean, String) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

consumeFromAnEmbeddedTopic(Consumer<?, ?>, boolean, String) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

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

埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

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

埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

consumeFromAnEmbeddedTopic(Consumer<?, ?>, String) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

埋め込みトピックの 1 つにコンシューマーをサブスクライブします。

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

1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromEmbeddedTopics(Consumer<?, ?>, boolean, String...) - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker

1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromEmbeddedTopics(Consumer<?, ?>, boolean, String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

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

1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

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

1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

consumeFromEmbeddedTopics(Consumer<?, ?>, String...) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker

1 つ以上の埋め込みトピックにコンシューマーをサブスクライブします。

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

Consumer オブジェクトのヘッダー。

CONSUMER_AWARE - Enum constant in enum class org.springframework.kafka.listener.ListenerType

コンシューマーを意識しています。

consumerAdded(String, Consumer<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory.Listener

新しいコンシューマーが作成されました。

consumerAdded(String, Consumer<K, V>) - クラス org.springframework.kafka.core のメソッド。MicrometerConsumerListener

ConsumerAwareListenerErrorHandler - Interface in org.springframework.kafka.listener

コンシューマーにアクセスできるエラーハンドラー。

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

個々の受信 Kafka メッセージを処理するためのリスナー。

ConsumerAwareRebalanceListener - Interface in org.springframework.kafka.listener

コンシューマーオブジェクトへのアクセスを提供するリバランスリスナー。

ConsumerAwareRecordRecoverer - Interface in org.springframework.kafka.listener

Consumer への参照の取得をサポートする ConsumerRecordRecoverer。

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

コンシューマーファクトリ <K, V> - org.springframework.kafka.core のインターフェース

Consumer インスタンスを生成する戦略。

ConsumerFactory. リスナー <K, V> - org.springframework.kafka.core のインターフェース

コンシューマーが追加または削除されるたびに呼び出されます。

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

コンシューマーが起動に失敗したときに発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

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

元のレコードの消費に失敗したコンシューマーグループを格納するために使用されるヘッダーの名前を設定します。

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

コンシューマーパーティションが一時停止したときに発行されるイベント。

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

提供されたソースとパーティションを使用してインスタンスを構築します。

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

コンシューマーパーティションが再開されたときに発行されるイベント。

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

提供されたソースとパーティションを使用してインスタンスを構築します。

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

コンシューマーが一時停止したときに発行されるイベント。

ConsumerPausedEvent(Object, Object, Collection<TopicPartition>) - クラス org.springframework.kafka.event. ConsumerPausedEvent のコンストラクター

提供されたソースとパーティションでインスタンスを構築します。

ConsumerPausedEvent(Object, Object, Collection<TopicPartition>, String) - クラス org.springframework.kafka.event. ConsumerPausedEvent のコンストラクター

提供されたソースとパーティションでインスタンスを構築します。

ConsumerPauseResumeEventPublisher - Interface in org.springframework.kafka.listener

コンシューマーの一時停止 / 再開イベントを発行できるオブジェクト。

コンシューマーポストプロセッサー <K, V> - org.springframework.kafka.core のインターフェース

新しく作成されたコンシューマーで後処理を実行するために、コンシューマーファクトリによって呼び出されます。

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

一般的なコンシューマープロパティ。

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

指定されたトピックをサブスクライブするコンテナーのプロパティを作成します。

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

指定されたパターンに一致するトピックをサブスクライブするコンテナーのプロパティを作成します。

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

提供されたトピックパーティションを自分自身に割り当てるコンテナーのプロパティを作成します。

consumerProps(String, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

<Integer, String> コンシューマーのテストプロパティを設定します。

consumerProps(String, String, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

<Integer, String> コンシューマーのテストプロパティを設定します。

consumerProps(String, String, EmbeddedKafkaBroker) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils

<Integer, String> コンシューマーのテストプロパティを設定します。

ConsumerRecordKeyCondition(K) - クラス org.springframework.kafka.test.assertj のコンストラクター。KafkaConditions.ConsumerRecordKeyCondition

ConsumerRecordKeyMatcher(K) - クラス org.springframework.kafka.test.hamcrest のコンストラクター。KafkaMatchers.ConsumerRecordKeyMatcher

ConsumerRecordKeyValueCondition(K, V) - クラス org.springframework.kafka.test.assertj のコンストラクター。KafkaConditions.ConsumerRecordKeyValueCondition

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

ユーザーがそのようなパラメーターを指定するときに、リスナーメソッドの引数を提供するために使用されます。

ConsumerRecordMetadata(RecordMetadata, TimestampType) - クラス org.springframework.kafka.listener.adapter. ConsumerRecordMetadata のコンストラクター

ConsumerRecordPartitionCondition(int) - クラス org.springframework.kafka.test.assertj のコンストラクター。KafkaConditions.ConsumerRecordPartitionCondition

ConsumerRecordPartitionMatcher(int) - クラス org.springframework.kafka.test.hamcrest のコンストラクター。KafkaMatchers.ConsumerRecordPartitionMatcher

ConsumerRecordRecoverer - Interface in org.springframework.kafka.listener

コンシューマーレコードを回復するための BiConsumerSE 拡張。

ConsumerRecordTimestampCondition(TimestampType, long) - クラス org.springframework.kafka.test.assertj のコンストラクター。KafkaConditions.ConsumerRecordTimestampCondition

ConsumerRecordTimestampMatcher(TimestampType, long) - クラス org.springframework.kafka.test.hamcrest のコンストラクター。KafkaMatchers.ConsumerRecordTimestampMatcher

ConsumerRecordValueCondition(V) - クラス org.springframework.kafka.test.assertj のコンストラクター。KafkaConditions.ConsumerRecordValueCondition

ConsumerRecordValueMatcher(V) - クラス org.springframework.kafka.test.hamcrest のコンストラクター。KafkaMatchers.ConsumerRecordValueMatcher

consumerRemoved(String, Consumer<K, V>) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory.Listener

既存のコンシューマーが削除されました。

consumerRemoved(String, Consumer<K, V>) - クラス org.springframework.kafka.core のメソッド。MicrometerConsumerListener

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

コンシューマーが再開されたときに発行されるイベント。

ConsumerResumedEvent(Object, Object, Collection<TopicPartition>) - クラス org.springframework.kafka.event. ConsumerResumedEvent のコンストラクター

提供されたソースとパーティションでインスタンスを構築します。

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

コンシューマーの認証または認可が失敗し、再試行されているときに発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

ConsumerRetryAuthEvent.Reason - org.springframework.kafka.event の Enum クラス

コンシューマーの認証を再試行する理由。

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

認証または認可の再試行が成功したときに発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

ConsumerSeekAware - Interface in org.springframework.kafka.listener

このインターフェースを実装するリスナーには、シーク操作の実行に使用できる ConsumerSeekAware.ConsumerSeekCallback が提供されます。

ConsumerSeekAware.ConsumerSeekCallback - org.springframework.kafka.listener のインターフェース

特定のオフセットをシークするためにリスナーが呼び出すことができるコールバック。

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

コンシューマーが起動したときに公開されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

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

コンシューマーが初期化するときに発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

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

コンシューマーが停止したときに発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

ConsumerStoppedEvent.Reason - org.springframework.kafka.event の Enum クラス

コンシューマーを停止する理由。

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

コンシューマーが停止したときに発行されるイベント。

ConsumerStoppingEvent(Object, Object, Consumer<?, ?>, Collection<TopicPartition>) - クラス org.springframework.kafka.event. ConsumerStoppingEvent のコンストラクター

提供されたソース、コンシューマー、パーティションでインスタンスを構築します。

コンテナーカスタマイザー <K, V, C> - org.springframework.kafka.config のインターフェース

コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。

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

このエンドポイントのサービスを担当するメッセージリスナーコンテナーを作成するために使用する KafkaListenerContainerFactory の Bean 名。

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

提供されている場合、このリスナーのリスナーコンテナーは、この値を名前として Collection<MessageListenerContainer> 型の Bean に追加されます。

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

リスナーコンテナーのグループ。

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

指定された名前でインスタンスを作成します。

ContainerGroup(String, List<MessageListenerContainer>) - クラス org.springframework.kafka.listener. ContainerGroup のコンストラクター

指定された名前とコンテナーを使用してインスタンスを作成します。

ContainerGroup(String, MessageListenerContainer...) - クラス org.springframework.kafka.listener. ContainerGroup のコンストラクター

指定された名前とコンテナーを使用してインスタンスを作成します。

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

前のグループのすべてのコンテナーがアイドル状態のときに、コンテナーグループの開始をシーケンスします。

ContainerGroupSequencer(ListenerContainerRegistry, long, String...) - クラス org.springframework.kafka.listener. ContainerGroupSequencer のコンストラクター

各グループのコンテナーを自動起動しないように設定します。

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

指定されたタイムスタンプの期限が切れていない場合に、特定のトピックの消費を取り消すマネージャー。

ContainerPartitionPausingBackOffManager(ListenerContainerRegistry, BackOffHandler) - クラス org.springframework.kafka.listener. ContainerPartitionPausingBackOffManager のコンストラクター

提供されたレジストリを使用してインスタンスを構築し、ハンドラーをバックオフします。

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

ContainerPartitionPausingBackOffManager のファクトリ。

ContainerPartitionPausingBackOffManagerFactory(ListenerContainerRegistry, ApplicationContext) - クラス org.springframework.kafka.listener. ContainerPartitionPausingBackOffManagerFactory のコンストラクター

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

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

バックオフのためにコンテナーを一時停止する BackOffHandler。

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

提供された ListenerContainerPauseService を使用してインスタンスを作成します。

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

ContainerPostProcessor の Bean 名を設定して、コンテナーの作成と構成後にコンテナーをカスタマイズできるようにします。

コンテナーポストプロセッサー <K, V, C> - org.springframework.kafka.config のインターフェース

コンテナーが作成および設定された後、コンテナーファクトリによって呼び出されます。

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

リスナーコンテナーのランタイムプロパティが含まれています。

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

指定されたトピックをサブスクライブするコンテナーのプロパティを作成します。

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

指定されたパターンに一致するトピックをサブスクライブするコンテナーのプロパティを作成します。

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

提供されたトピックパーティションを自分自身に割り当てるコンテナーのプロパティを作成します。

ContainerProperties.AckMode - org.springframework.kafka.listener の Enum クラス

オフセットコミット動作の列挙。

ContainerProperties.AssignmentCommitOption - org.springframework.kafka.listener の Enum クラス

割り当て中のオフセットコミット動作。

ContainerProperties.EOSMode - org.springframework.kafka.listener の Enum クラス

厳密に 1 回のセマンティクスのモード。

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

コンテナー停止時に発行されるイベント。

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

提供されたソースとコンテナーでインスタンスを構築します。

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

リスナーコンテナーをテストするためのユーティリティ。

contains(MessageListenerContainer) - クラス org.springframework.kafka.listener のメソッド。ContainerGroup

指定されたコンテナーがこのグループにある場合は true を返します。

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

必要な型への変換を実行するために MessageHeaders.CONTENT_TYPE ヘッダーと組み合わせて使用する SmartMessageConverter ( CompositeMessageConverter など) の Bean 名を設定します。

Context(String, List<DestinationTopic.Properties>) - クラス org.springframework.kafka.retrytopic のコンストラクター。DestinationTopicProcessor.Context

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

型 Continuation のメソッド引数の何もしないリゾルバー。

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

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

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

変換失敗のリストを含むヘッダー（バッチリスナーのみ）。

ConversionException - Exception Class in org.springframework.kafka.support.converter

変換の例外。

ConversionException(String, Throwable) - Constructor for exception class org.springframework.kafka.support.converter.ConversionException

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

ConversionException(String, List<ConsumerRecord<?, ?>>, Throwable) - Constructor for exception class org.springframework.kafka.support.converter.ConversionException

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

ConversionException(String, ConsumerRecord<?, ?>, Throwable) - Constructor for exception class org.springframework.kafka.support.converter.ConversionException

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

ConversionException(String, Message<?>, Throwable) - Constructor for exception class org.springframework.kafka.support.converter.ConversionException

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

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

レコード値を変換します。

convertFromInternal(Message<?>, Class<?>, Object) - クラス org.springframework.kafka.support.converter のメソッド。MappingJacksonParameterizedConverter

ConvertingMessageListener<V> - org.springframework.kafka.listener.adapter のクラス

指定された MessageConverter を使用して受信した ConsumerRecord の変換を実装し、結果を指定された MessageListener に渡す AcknowledgingConsumerAwareMessageListener アダプター。

ConvertingMessageListener(MessageListener<?, V>, Class<V>) - クラス org.springframework.kafka.listener.adapter. ConvertingMessageListener のコンストラクター

提供された MessageListener および ClassSE を、変換後の ConsumerRecord の値の目的の型として使用してインスタンスを構築します。

convertPayload(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。ByteArrayJsonMessageConverter

convertPayload(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。BytesJsonMessageConverter

convertPayload(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。JsonMessageConverter

convertPayload(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

サブクラスはペイロードを変換できます。デフォルトでは、変更されずに Kafka に送信されます。

convertPayload(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。ProjectingMessageConverter

convertPayload(Message<?>) - クラス org.springframework.kafka.support.converter のメソッド。StringJsonMessageConverter

copyWithConfigurationOverride(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

インスタンスのプロパティと指定されたプロパティをコピーして、新しいプロデューサーファクトリを作成します。

copyWithConfigurationOverride(Map<String, Object>) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

インスタンスのプロパティと指定されたプロパティをコピーして、新しいプロデューサーファクトリを作成します。

copyWithType(TypeReference<? super X>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

新しいターゲット型参照が使用されることを除いて、同じ構成でこのデシリアライザーをコピーします。

copyWithType(TypeReference<? super X>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

新しいターゲット型参照が使用されることを除いて、同じ構成でこの serde をコピーします。

copyWithType(TypeReference<? super X>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

新しいターゲット型参照が使用されることを除いて、このシリアライザーを同じ構成でコピーします。

copyWithType(JavaType) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

新しいターゲット java 型が使用されることを除いて、このデシリアライザーを同じ構成でコピーします。

copyWithType(JavaType) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

新しいターゲット java 型が使用されることを除いて、同じ構成でこの Serde をコピーします。

copyWithType(JavaType) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

新しいターゲット java 型が使用されることを除いて、同じ構成でこのシリアライザーをコピーします。

copyWithType(Class<? super X>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

新しいターゲット型が使用されることを除いて、同じ構成でこのデシリアライザーをコピーします。

copyWithType(Class<? super X>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerde

新しいターゲット型が使用されることを除いて、同じ構成でこの Serde をコピーします。

copyWithType(Class<? super X>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

新しいターゲット型参照が使用されることを除いて、このシリアライザーを同じ構成でコピーします。

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

リクエスト / 応答を相互に関連付けるための情報を含むヘッダー。

CorrelationKey - org.springframework.kafka.requestreply のクラス

ハッシュキーとして使用できる byte[] のラッパー。

CorrelationKey(byte[]) - クラス org.springframework.kafka.requestreply. CorrelationKey のコンストラクター

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

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

ackCount を超えた後、保留中のオフセットをコミットします。

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

EmbeddedKafkaBroker のブローカーの数。

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

ackCount を超えた後、または ackTime が経過した後、保留中のオフセットをコミットします。

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

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

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

create(Function<ProducerRecord<?, ?>, KafkaOperations<?, ?>>, BiFunction<ConsumerRecord<?, ?>, Exception, TopicPartition>) - インターフェース org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator

提供されたプロパティを使用して DeadLetterPublishingRecoverer を作成します。

create(Headers, Exception, boolean, DeadLetterPublishingRecoverer.HeaderNames) - インターフェース org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.ExceptionHeadersCreator

例外ヘッダーを作成します。

create(KafkaOperations<?, ?>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

提供されたテンプレートを使用して RetryTopicConfiguration を作成します。

create(EmbeddedKafka) - Static method in class org.springframework.kafka.test.EmbeddedKafkaBrokerFactory

EmbeddedKafka アノテーションに基づいて EmbeddedKafkaBroker を作成します。

create(EmbeddedKafka, Function<String, String>) - Static method in class org.springframework.kafka.test.EmbeddedKafkaBrokerFactory

EmbeddedKafka アノテーションに基づいて EmbeddedKafkaBroker を作成します。

createAccessor(Message<?>) - クラス org.springframework.kafka.support のメソッド。KafkaMessageHeaderAccessor

createAdmin() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin

AdminClient クラスを使用して新しい Admin クライアントインスタンスを作成します。

createClientMetrics(C, List<Tag>) - クラス org.springframework.kafka.core のメソッド。KafkaMetricsSupport

提供された Kafka クライアントおよびメトリクスタグの io.micrometer.core.instrument.binder.kafka.KafkaMetrics インスタンスを作成します。

createClientMetrics(KafkaStreams, List<Tag>) - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsMicrometerListener

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

このメソッドをオーバーライドして、RetryTopicComponentFactory のサブクラスに異なるコンポーネント実装またはサブクラスを提供します。

createConsumer() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

プロパティで構成されているグループ ID とクライアント ID を使用してコンシューマーを作成します。

createConsumer(String) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

コンシューマーを作成し、存在する場合は client.id プロパティにサフィックスを追加します。

createConsumer(String, String) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

明示的なグループ ID でコンシューマーを作成します。さらに、両方が存在する場合、クライアント ID サフィックスが client.id プロパティに追加されます。

createConsumer(String, String, String) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

明示的なグループ ID でコンシューマーを作成します。さらに、クライアント ID サフィックスが clientIdPrefix に追加され、存在する場合は client.id プロパティをオーバーライドします。

createConsumer(String, String, String) - クラス org.springframework.kafka.mock のメソッド。MockConsumerFactory

createConsumer(String, String, String, Properties) - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory

明示的なグループ ID でコンシューマーを作成します。さらに、クライアント ID サフィックスが clientIdPrefix に追加され、存在する場合は client.id プロパティをオーバーライドします。

createConsumer(String, String, String, Properties) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

createConsumer(String, String, String, Properties) - クラス org.springframework.kafka.mock のメソッド。MockConsumerFactory

createContainer(String...) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

createContainer(String...) - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerContainerFactory

リスナーなしでコンテナーを作成して構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。

createContainer(Pattern) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

createContainer(Pattern) - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerContainerFactory

リスナーなしでコンテナーを作成して構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。

createContainer(KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

createContainer(TopicPartitionOffset...) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

createContainer(TopicPartitionOffset...) - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerContainerFactory

リスナーなしでコンテナーを作成して構成します。KafkaListener アノテーションに使用されないコンテナーを作成するために使用されます。

createContainerInstance(KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

空のコンテナーインスタンスを作成します。

createContainerInstance(KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。ConcurrentKafkaListenerContainerFactory

createContext(long, String, TopicPartition, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。KafkaConsumerBackoffManager

createDefaultErrorHandlerInstance(DeadLetterPublishingRecoverer) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

createDelegates(String, Map<String, ?>, boolean) - Static method in class org.springframework.kafka.support.serializer.DelegatingDeserializer

createDelegates(String, Map<String, ?>, boolean) - Static method in class org.springframework.kafka.support.serializer.DelegatingSerializer

createEndpointCustomizer() - クラス org.springframework.kafka.retrytopic のメソッド。EndpointCustomizerFactory

createEndpointCustomizer(EndpointHandlerMethod, DestinationTopic.Properties) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurer

createErrorHandler(DeadLetterPublishingRecoverer) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

createHandlerMethodWith(Object, Method) - Static method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer

createHandlerMethodWith(Object, String) - Static method in class org.springframework.kafka.retrytopic.RetryTopicConfigurer

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

createInstanceAndConfigure(Map<String, ?>, boolean, Map<String, Deserializer<?>>, String, String) - Static method in class org.springframework.kafka.support.serializer.DelegatingDeserializer

createInstanceAndConfigure(Map<String, ?>, boolean, Map<String, Serializer<?>>, String, String) - Static method in class org.springframework.kafka.support.serializer.DelegatingSerializer

createInternalRetryTopicClock() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicComponentFactory

トピックの再試行プロセスで時間関連のすべての操作に使用される ClockSE インスタンスを作成します。

createInvocableHandlerMethod(Object, Method) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaMessageHandlerMethodFactory

createKafkaConsumer(String, String, String, Properties) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

createKafkaConsumer(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

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

サブクラスは、DefaultKafkaProducerFactory.CloseSafeProducer にラップされる生のプロデューサーを返す必要があります。

createListenerContainer(KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

createListenerContainer(KafkaListenerEndpoint) - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerContainerFactory

指定された KafkaListenerEndpoint の MessageListenerContainer を作成します。

createListenerContainer(KafkaListenerEndpoint, KafkaListenerContainerFactory<?>) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

指定されたファクトリを使用して、新しい MessageListenerContainer を作成して開始します。

createManagerFor(Collection<T>, Collection<T>) - Static method in class org.springframework.kafka.support.AllowDenyCollectionManager

createManagerFor(Collection<T>, Collection<T>, Collection<Predicate<T>>) - Static method in class org.springframework.kafka.support.AllowDenyCollectionManager

createMappings(String) - Static method in class org.springframework.kafka.support.serializer.JsonSerializer

createMessageListener(MessageListenerContainer, MessageConverter) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

指定されたコンテナーに対してこのエンドポイントを提供できる MessageListener を作成します。

createMessageListener(MessageListenerContainer, MessageConverter) - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint

createMessageListenerInstance(MessageConverter) - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint

空の MessagingMessageListenerAdapter インスタンスを作成します。

createMessagingErrorMessage(String, Object) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

createNewTopicBeans(Collection<String>, RetryTopicConfiguration.TopicCreation) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurer

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

createNonTransactionalProducer() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

非トランザクションプロデューサーを作成します。

createNonTransactionalProducer() - クラス org.springframework.kafka.mock のメソッド。MockProducerFactory

createOffsetAndMetadata(MessageListenerContainer, long) - Static method in class org.springframework.kafka.listener.ListenerUtils

指定されたコンテナーとオフセットを使用して新しい OffsetAndMetadata を作成します。

createOrModifyTopics(NewTopic...) - クラス org.springframework.kafka.core のメソッド。KafkaAdmin

createOrModifyTopics(NewTopic...) - インターフェース org.springframework.kafka.core のメソッド。KafkaAdminOperations

トピックが存在しない場合は作成するか、必要に応じてパーティションの数を増やします。

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

createProducer() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

ファクトリがそのように構成されている場合にトランザクションになるプロデューサーを作成します。

createProducer() - クラス org.springframework.kafka.mock のメソッド。MockProducerFactory

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

createProducer(String) - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory

オーバーライドされたトランザクション ID プレフィックスを使用してプロデューサーを作成します。

createProducer(String) - クラス org.springframework.kafka.mock のメソッド。MockProducerFactory

createProducerRecord(ConsumerRecord<?, ?>, TopicPartition, Headers, byte[], byte[]) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

サブクラスはこのメソッドをオーバーライドして、DLQ に送信するプロデューサーレコードをカスタマイズできます。

createProperties() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopicPropertiesFactory

createRawConsumer(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

Consumer を作成します。

createRawProducer(Map<String, Object>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

createRetryTopicNamesProvider(DestinationTopic.Properties) - インターフェース org.springframework.kafka.retrytopic のメソッド。RetryTopicNamesProviderFactory

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

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

ConsumerRebalanceListener インスタンスのデフォルトの実装を返します。

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

サブクラスは、DefaultKafkaProducerFactory.getCache() からのプロデューサー、または DefaultKafkaProducerFactory.CloseSafeProducer にラップされた新しい生のプロデューサーを返す必要があります。

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

customBackoff(SleepingBackOffPolicy<?>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationBuilder

カスタム SleepingBackOffPolicy を構成します。

customize(KafkaStreams) - クラス org.springframework.kafka.config のメソッド。CompositeKafkaStreamsCustomizer

customize(KafkaStreams) - インターフェース org.springframework.kafka.config のメソッド。KafkaStreamsCustomizer

StreamsBuilderFactoryBean がデフォルト構成を適用した後、KafkaStreams のインスタンスをカスタマイズします。

customizeAndRegisterTopics(RetryTopicNamesProviderFactory.RetryTopicNamesProvider, MethodKafkaListenerEndpoint<?, ?>) - クラス org.springframework.kafka.retrytopic のメソッド。EndpointCustomizerFactory

customizeContainer(C, KafkaListenerEndpoint) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

customizeDeadLetterPublishingRecoverer(Consumer<DeadLetterPublishingRecoverer>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport.CustomizersConfigurer

レコードを再試行トピックおよび DLT に転送するために使用される DeadLetterPublishingRecoverer をカスタマイズします。

customizeEndpointAndCollectTopics(T) - インターフェース org.springframework.kafka.retrytopic のメソッド。EndpointCustomizer

エンドポイントをカスタマイズし、このエンドポイント用に生成されたトピック名を返します。

customizeErrorHandler(Consumer<DefaultErrorHandler>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport.CustomizersConfigurer

機能に使用される CommonErrorHandler インスタンスをカスタマイズします。

customizeListenerContainer(Consumer<ConcurrentMessageListenerContainer<?, ?>>) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurationSupport.CustomizersConfigurer

再試行および DLT コンシューマー用に作成された ConcurrentMessageListenerContainer インスタンスをカスタマイズします。

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