インデックス

S

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

同じバックオフ間隔で行われた連続試行に対するトピック再利用戦略。

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

SameIntervalTopicReuseStrategy を構成します。

SameIntervalTopicReuseStrategy - Enum Class in org.springframework.kafka.retrytopic

複数の連続した再試行のバックオフ間隔が同じ場合のトピック再利用の戦略。

scheduler - Variable in class org.springframework.kafka.core.KafkaMetricsSupport

secondary() - Method in class org.springframework.kafka.core.ABSwitchCluster

セカンダリクラスターを使用します。

seek(String, int, long) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

シーク操作を実行します。

seek(String, int, Function<Long, Long>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

指定された関数に基づいてシーク操作を実行し、シークするオフセットを計算します。

seekOrRecover(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer, boolean, RecoveryStrategy, LogAccessor, KafkaException.Level) - Static method in class org.springframework.kafka.listener.SeekUtils

残りのレコードを探し、オプションで最初のレコードを回復します。

seekOrRecover(Exception, List<ConsumerRecord<?, ?>>, Consumer<?, ?>, MessageListenerContainer, boolean, BiPredicate<ConsumerRecord<?, ?>, Exception>, LogAccessor, KafkaException.Level) - Static method in class org.springframework.kafka.listener.SeekUtils

残りのレコードを探し、オプションで最初のレコードを回復します。

seekPartitions(Consumer<?, ?>, Map<TopicPartition, Long>, LogAccessor) - Static method in class org.springframework.kafka.listener.SeekUtils

各パーティションでシーク操作を実行します。

seekPosition() - Element in annotation interface org.springframework.kafka.annotation.PartitionOffset

パーティション割り当て時に検索する位置。

seekRelative(String, int, long, boolean) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

開始位置、終了位置、現在の位置に対してシークを実行します。

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

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

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

このエラーハンドラーが失敗したレコードと残りのレコード（または失敗したレコードが回復した後の残りのレコードのみ）に対してシークを実行する場合は true を返します。

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

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

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

最初に割り当てられたすべてのパーティションを探します。

seekToBeginning(String, int) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

シークから開始操作を実行します。

seekToBeginning(Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

シークから開始操作を実行します。

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

割り当てられたすべてのパーティションを最後まで探します。

seekToEnd(String, int) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

操作を終了するシークを実行します。

seekToEnd(Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

操作を終了するシークを実行します。

seekToTimestamp(long) - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware

タイムスタンプで表されるオフセットに割り当てられたすべてのパーティションを探します。

seekToTimestamp(String, int, long) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

タイムスタンプ以上の最初のオフセットまでシークを実行します。

seekToTimestamp(Collection<TopicPartition>, long) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback

タイムスタンプ以上の最初のオフセットまでシークを実行します。

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

ユーティリティを探します。

selectImports(AnnotationMetadata) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerConfigurationSelector

selfLog(String, LogAccessor) - Method in exception org.springframework.kafka.KafkaException

この例外をログレベルで記録します。

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

キーまたはパーティションなしで、提供されたトピックにデータを送信します。

send(String, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

send(String, Integer, Long, K, V) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

提供されたキーとパーティションを使用して、提供されたトピックにデータを送信します。

send(String, Integer, Long, K, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

send(String, Integer, K, V) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

提供されたキーとパーティションを使用して、提供されたトピックにデータを送信します。

send(String, Integer, K, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

send(String, K, V) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

提供されたキーを使用して、パーティションなしで、提供されたトピックにデータを送信します。

send(String, K, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

send(ProducerRecord<Object, Object>, KafkaOperations<Object, Object>, ConsumerRecord<?, ?>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

レコードを送信します。

send(ProducerRecord<K, V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory.CloseSafeProducer

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

提供された ProducerRecord を送信します。

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

send(ProducerRecord<K, V>, Callback) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory.CloseSafeProducer

send(Message<?>) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

メッセージヘッダーにルーティング情報を含むメッセージを送信します。

send(Message<?>) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

sendAndReceive(ProducerRecord<K, V>) - インターフェース org.springframework.kafka.requestreply のメソッド。ReplyingKafkaOperations

リクエストを送信し、デフォルトのタイムアウトで応答を受信します。

sendAndReceive(ProducerRecord<K, V>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

sendAndReceive(ProducerRecord<K, V>, Duration) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

sendAndReceive(ProducerRecord<K, V>, Duration) - インターフェース org.springframework.kafka.requestreply のメソッド。ReplyingKafkaOperations

リクエストを送信し、返信を受け取ります。

sendAndReceive(Message<?>) - インターフェース org.springframework.kafka.requestreply のメソッド。ReplyingKafkaOperations

リクエストメッセージを送信し、デフォルトのタイムアウトで応答メッセージを受信します。

sendAndReceive(Message<?>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

sendAndReceive(Message<?>, Duration) - インターフェース org.springframework.kafka.requestreply のメソッド。ReplyingKafkaOperations

リクエストメッセージを送信し、応答メッセージを受信します。

sendAndReceive(Message<?>, Duration) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

sendAndReceive(Message<?>, Duration, ParameterizedTypeReference<P>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

sendAndReceive(Message<?>, ParameterizedTypeReference<P>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

sendAndReceive(Message<?>, Duration, ParameterizedTypeReference<P>) - インターフェース org.springframework.kafka.requestreply のメソッド。ReplyingKafkaOperations

リクエストメッセージを送信し、応答メッセージを受信します。

sendAndReceive(Message<?>, ParameterizedTypeReference<P>) - インターフェース org.springframework.kafka.requestreply のメソッド。ReplyingKafkaOperations

リクエストメッセージを送信し、応答メッセージを受信します。

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

キーまたはパーティションなしでデータをデフォルトトピックに送信します。

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

sendDefault(Integer, Long, K, V) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

提供されたキーとパーティションを使用して、データをデフォルトのトピックに送信します。

sendDefault(Integer, Long, K, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

sendDefault(Integer, K, V) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

提供されたキーとパーティションを使用して、データをデフォルトのトピックに送信します。

sendDefault(Integer, K, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

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

提供されたキーを使用してパーティションなしでデータをデフォルトのトピックに送信します。

sendDefault(K, V) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory.CloseSafeProducer

sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations

トランザクションで実行する場合は、コンシューマーオフセットをトランザクションに送信します。

sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

sendOffsetsToTransaction(Map<TopicPartition, OffsetAndMetadata>, ConsumerGroupMetadata) - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate

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

結果をトピックに送信します。

SendResult< K , V > - Class in org.springframework.kafka.support

送信後の CompletableFutureSE の結果。

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

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

sendTo レコードコンポーネントの値を返します。

SerializationUtils - org.springframework.kafka.support.serializer のクラス

直列化のためのユーティリティ。

serialize(String, Headers, T) - クラス org.springframework.kafka.support.serializer のメソッド。ToStringSerializer

serialize(String, T) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer

serialize(String, T) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

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

serialize(String, T) - クラス org.springframework.kafka.support.serializer のメソッド。ToStringSerializer

serialize(String, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerializer

serialize(String, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTypeSerializer

serialize(String, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingSerializer

serialize(String, Object) - クラス org.springframework.kafka.support.serializer のメソッド。StringOrBytesSerializer

serialize(String, Headers, T) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer

serialize(String, Headers, T) - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer

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

serialize(String, Headers, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTopicSerializer

serialize(String, Headers, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingByTypeSerializer

serialize(String, Headers, Object) - クラス org.springframework.kafka.support.serializer のメソッド。DelegatingSerializer

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

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

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

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

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

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

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

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

コンテナーがリカバリされたレコードのオフセットをコミットしないようにするには、false に設定します（エラーハンドラー自体が例外をスローしない場合）。

setAckAfterHandle(boolean) - クラス org.springframework.kafka.listener のメソッド。CommonLoggingErrorHandler

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

setAckAfterHandle(boolean) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

setAckCount(int) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

ContainerProperties.AckMode.COUNT または ContainerProperties.AckMode.COUNT_TIME が使用されているときにオフセットがコミットされるまでの未処理のレコード数の数を設定します。

setAckDiscarded(boolean) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

AbstractKafkaListenerEndpoint.setRecordFilterStrategy(RecordFilterStrategy) が破棄されたメッセージを確認する場合は true に設定します。

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

フィルター戦略が使用されているときに破棄を確認するには、true に設定します。

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

このエンドポイントのコンテナーの ackMode を設定して、提供時のデフォルトを上書きします。

setAckMode(ContainerProperties.AckMode) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

自動 ack（構成プロパティ内）が false の場合に使用する ack モードを設定します。

setAcknowledgementCommitCallback(AcknowledgementCommitCallback) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

確認コミットが完了したときに呼び出されるコールバックを設定します。

setAckTime(long) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

ContainerProperties.AckMode.TIME または ContainerProperties.AckMode.COUNT_TIME の使用時に未処理のオフセットがコミットされるまでの時間 (ms) を設定します。

setAddTypeInfo(boolean) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer

型情報ヘッダーの追加を無効にするには、false に設定します。

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

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

型情報ヘッダーの追加を無効にするには、false に設定します。

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

型情報ヘッダーの追加を無効にするには、false に設定します。

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

管理操作のタイムアウトを秒単位で設定します (例:

setAdviceChain(Advice...) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

リスナー Advice の チェーンを設定します。null であってはならず、null 要素を持つこともできません。

setAfterRollbackProcessor(AfterRollbackProcessor<? super K, ? super V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

トランザクションのロールバック後に呼び出すプロセッサーを設定します。通常、未処理のトピック / パーティションを探してレコードを再処理します。

setAfterRollbackProcessor(AfterRollbackProcessor<? super K, ? super V>) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

ロールバック後に未処理のレコードでシークを実行するようにプロセッサーを設定します。

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

テンプレートがトランザクションの場合に非トランザクション送信を許可するには、true に設定します。

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

同時実行性が 1 のみの場合に、子コンテナーの client.id へのサフィックスの追加を抑制するには false に設定します。

setAlwaysStartAfterRefresh(boolean) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

デフォルトでは、コンテキストがリフレッシュされた後にエンドポイントに登録されたコンテナーは、autoStartup プロパティに関係なく、SmartLifecycle 契約に準拠するためにすぐに起動されます。autoStartup はコンテキストの初期化時にのみ考慮されます。

setAppendOriginalHeaders(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

現在の「元の」ヘッダー (トピック、パーティションなど) がすでに存在する場合にそれを追加しない場合は、false に設定します。

setAppendOriginalHeaders(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

現在の「元の」ヘッダー (トピック、パーティションなど) がすでに存在する場合にそれを追加しない場合は、false に設定します。

setApplicationContext(ApplicationContext) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

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

setApplicationContext(ApplicationContext) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

setApplicationContext(ApplicationContext) - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory

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

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

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

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

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

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

setApplicationContext(ApplicationContext) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

setApplicationContext(ApplicationContext) - クラス org.springframework.kafka.listener のメソッド。ContainerGroupSequencer

setApplicationContext(ApplicationContext) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver

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

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

setApplicationEventPublisher(ApplicationEventPublisher) - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory

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

setApplicationEventPublisher(ApplicationEventPublisher) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

setAssignmentCommitOption(ContainerProperties.AssignmentCommitOption) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

割り当てコミットオプションを設定します。

setAsyncAcks(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

非同期レコード確認応答をサポートするには、true に設定します。

setAuthExceptionRetryInterval(Duration) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

AuthenticationException または org.apache.kafka.common.errors.AuthorizationException が KafkaConsumer によってスローされた後の再試行の間隔を設定します。

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

コンテキストの初期化中にトピックの自動作成を抑制するには、false に設定します。

setAutoStartup(boolean) - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory

このファクトリによって作成されたコンテナーを自動的に起動するかどうかを設定します。

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

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

setAutoStartup(boolean) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

setAutoStartup(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerGroupSequencer

自動的に起動しないようにするには、false に設定します。

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

autoStartup を設定します。

setAutoStartup(boolean) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

setAutoStartup(Boolean) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

このエンドポイントのコンテナーの autoStartup を設定します。

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

autoStartup boolean フラグを指定します。

setBackOffFunction(BiFunction<ConsumerRecord<?, ?>, Exception, BackOff>) - クラス org.springframework.kafka.listener のメソッド。FailedRecordProcessor

コンシューマーレコードや例外に基づいて、使用する BackOff を動的に決定する関数を設定します。

setBackOffHandler(BackOffHandler) - クラス org.springframework.kafka.listener のメソッド。ContainerPartitionPausingBackOffManagerFactory

作成されたハンドラーで使用するバックオフハンドラーを設定します。

setBatchInterceptor(BatchInterceptor<K, V>) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

レコードリスナーを呼び出す前に呼び出されるインターセプターを設定します。

setBatchInterceptor(BatchInterceptor<K, V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

リスナーを呼び出す前後に呼び出されるバッチインターセプターを設定します。

setBatchListener(boolean) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

このエンドポイントがバッチリスナーを作成する必要がある場合は、true に設定します。

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

このエンドポイントがバッチリスナーを作成する必要がある場合は、true に設定します。

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

バッチリスナーに動的な引数の型の一致が必要な場合に使用するメッセージコンバーターを設定します。

setBatchMessageConverter(BatchMessageConverter) - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter

BatchMessageConverter を設定します。

setBatchRecoverAfterRollback(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

ロールバック後のバッチリカバリを有効にします。

setBatchToRecordAdapter(BatchToRecordAdapter<K, V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

BatchToRecordAdapter を設定します。

setBatchToRecordAdapter(BatchToRecordAdapter<K, V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

BatchToRecordAdapter を設定します。

setBatchToRecordAdapter(BatchToRecordAdapter<K, V>) - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter

BatchToRecordAdapter を設定します。

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

このエンドポイントを管理する必要があるオブジェクトインスタンスを設定します。

setBeanClassLoader(ClassLoader) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

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

setBeanClassLoader(ClassLoader) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

setBeanFactory(BeanFactory) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

BeanFactory を使用可能にするかどうかはオプションです。設定されていない場合、KafkaListenerConfigurer Bean は自動検出されず、endpoint registry を明示的に構成する必要があります。

setBeanFactory(BeanFactory) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

setBeanFactory(BeanFactory) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

BeanFactory は、KafkaListenerEndpointRegistrar.setContainerFactoryBeanName(java.lang.String) と組み合わせて使用する必要があるだけです。

setBeanFactory(BeanFactory) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurer

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

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

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

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

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

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

setBeanName(String) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

setBeanResolver(BeanResolver) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

ランタイム SpEL 式の Bean リゾルバーを設定します。

setBinaryCorrelation(boolean) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

バイナリ表現ではなく、相関関係の文字列表現を correlationId として使用するには、false に設定します。

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

ブロック再試行で使用される BackOff を設定します。

setBlockingRetryableExceptions(Class<? extends Exception>...) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

ブロッキングを介して再試行する例外を指定します。

setBootstrapServersSupplier(Supplier<String>) - クラス org.springframework.kafka.core のメソッド。KafkaResourceFactory

サブクラスで構成されているものを上書きするように、ブートストラップサーバーリストのサプライヤーを設定します。

setCallbackForAsyncFailure(BiConsumer<ConsumerRecord<K, V>, RuntimeException>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

CompletableFutureSE と Mono の両方の失敗に対して再試行コールバックを設定します。

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

false に設定すると、トピック名の大文字と小文字が区別されなくなります。

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

ディープ例外の原因 チェーントラバースを有効にするフラグを設定します。

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

初期化中にコンシューマースレッド名を変更するようコンテナーに指示するには、true に設定します。

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

初期化中にコンシューマースレッド名を変更するようコンテナーに指示するには、true に設定します。

setCharset(Charset) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

メソッド引数およびその他の String/byte[] 変換で byte[] を String に変換するときに使用する文字セットを設定します。

setCharset(Charset) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

文字列値のヘッダーを byte[] との間でマッピングするときに使用する文字セットを設定します。

setCharset(Charset) - クラス org.springframework.kafka.support.serializer のメソッド。ParseStringDeserializer

byte[] を StringSE に変換するときに使用する文字セットを設定します。

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

StringSE を byte[] に変換するときに使用する文字セットを設定します。

setCheckDeserExWhenKeyNull(boolean) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

null キーを受信したときに、常に DeserializationException ヘッダーをチェックするには、true に設定します。

setCheckDeserExWhenValueNull(boolean) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

null 値を受け取ったときに、常に DeserializationException ヘッダーをチェックするには、true に設定します。

setClassIdFieldName(String) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

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

型情報のヘッダー名を設定します。

setClassIdFieldName(String) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

型情報のヘッダー名を設定します。

setClassifications(Map<Class<? extends Throwable>, Boolean>, boolean) - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier

例外の分類を設定して、例外によって (使い果たされるまで) 再試行するかどうかを決定します。

setClassifications(Map<Class<? extends Throwable>, Boolean>, boolean) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

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

setClientId(String) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

クライアント ID を設定します。コンシューマーファクトリの client.id プロパティを上書きします。

setClientId(String) - クラス org.springframework.kafka.listener のメソッド。ShareKafkaMessageListenerContainer

コンシューマー用に使用する client.id を設定します。

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

クライアント ID プレフィックスを設定します。コンシューマー構成プロパティのクライアント ID をオーバーライドします。

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

client.id コンシューマープロパティに追加するサフィックスを設定します（コンシューマーファクトリがサポートしている場合）。

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

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

KafkaStreams.close(Duration) 操作のタイムアウトを秒単位で指定します。

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

クローズタイムアウトを秒単位で設定します。

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

プロデューサーを閉じるときに待機する最大時間を設定します。デフォルトは 5 秒です。

setCloseTimeout(Duration) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

プロデューサーを閉じるときに待機する最大時間を設定します。デフォルトは 5 秒です。

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

クラスター ID を設定します。

setCommitCallback(OffsetCommitCallback) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

コミットコールバックを設定します。デフォルトでは、単純なロギングコールバックを使用して、DEBUG レベルでの成功と ERROR レベルでの失敗をログに記録します。

setCommitLogLevel(LogIfLevelEnabled.Level) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

オフセットコミットをログに記録するレベルを設定します。

setCommitRecovered(boolean) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler

回復されたレコードのオフセットをコミットするには、true に設定します。

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

回復されたレコードのオフセットをコミットするには、true に設定します。

setCommitRetries(int) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

true に設定された ConsumerProperties.setSyncCommits(boolean) を使用しているときに、コンシューマーによって RetriableCommitFailedException がスローされたときに許可される再試行回数を設定します。

setCommitTimeout(Duration) - クラス org.springframework.kafka.requestreply のメソッド。AggregatingReplyingKafkaTemplate

オフセットをコミットするときに使用するタイムアウトを設定します。

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

レコードリスナーとバッチリスナーの両方のエラーを処理できる CommonErrorHandler を設定します。

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

レコードリスナーとバッチリスナーの両方のエラーを処理できる CommonErrorHandler を設定します。

setConcurrency(int) - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory

このファクトリによって作成されたコンテナーの同時実行性を設定します。

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

同時に実行されている KafkaMessageListenerContainer の最大数。

setConcurrency(int) - クラス org.springframework.kafka.listener のメソッド。ShareKafkaMessageListenerContainer

同時実行のレベルを設定します。

setConcurrency(Integer) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

このエンドポイントのコンテナーの同時実行性を設定します。

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

コンテナーの同時実行性を指定します。

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

プログラムで提供されるデシリアライザー (コンストラクターまたは setter 経由) がコンシューマー構成を使用して構成されないようにするには、false (デフォルトは true) に設定します。例:

setConfigureDeserializers(boolean) - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory

プログラムで提供されるデシリアライザー (コンストラクターまたは setter 経由) がコンシューマー構成を使用して構成されないようにするには、false (デフォルトは true) に設定します。例:

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

false（デフォルトは true）に設定して、プログラムで提供されたシリアライザー（コンストラクターまたは setter を介して）がプロデューサー構成を使用して構成されないようにします。

setConsumerFactory(ConsumerFactory<? super K, ? super V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

使用する ConsumerFactory を指定します。

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

受信操作用のコンシューマーファクトリを設定します。

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

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

setConsumerProperties(Properties) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

コンシューマーファクトリによって提供されるコンシューマープロパティとマージされるコンシューマープロパティを設定します。ここのプロパティは、コンシューマーファクトリの同じ名前のプロパティよりも優先されます。

setConsumerRebalanceListener(ConsumerRebalanceListener) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

ユーザー定義の ConsumerRebalanceListener 実装を設定します。

setConsumerRecordFormatter(Function<ConsumerRecord<?, ?>, String>) - Static method in class org.springframework.kafka.support.KafkaUtils

ConsumerRecord をログに記録するためのフォーマッターを設定します。

setConsumerStartTimeout(Duration) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

エラーをログに記録する前にコンシューマースレッドが開始するのを待つようにタイムアウトを設定します。

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

setContainerCustomizer(ContainerCustomizer<K, V, C>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

コンテナーの作成後にコンテナーをさらに構成するために使用されるカスタマイザーを設定します。

setContainerFactory(KafkaListenerContainerFactory<?>) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

KafkaListenerEndpoint が null コンテナーファクトリに登録されている場合に使用する KafkaListenerContainerFactory を設定します。

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

KafkaListenerEndpoint が null コンテナーファクトリに登録されている場合に使用する KafkaListenerContainerFactory の Bean 名を設定します。

setContainerPostProcessor(ContainerPostProcessor<?, ?, ?>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

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

setContentClassIdFieldName(String) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

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

コンテナーオブジェクトのコンテンツ型情報のヘッダー名を設定します。

setContentClassIdFieldName(String) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

コンテナーオブジェクトのコンテンツ型情報のヘッダー名を設定します。

setControlFlag(KafkaJaasLoginModuleInitializer.ControlFlag) - クラス org.springframework.kafka.security.jaas のメソッド。KafkaJaasLoginModuleInitializer

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

相関 ID のカスタムヘッダー名を設定します。

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

相関 ID のカスタムヘッダー名を設定します。

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

相関 ID のカスタムヘッダー名を設定します。

setCorrelationHeaderName(String) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

相関 ID のカスタムヘッダー名を設定します。

setCorrelationIdStrategy(Function<ProducerRecord<K, V>, CorrelationKey>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

リクエストレコードごとに一意の相関キーを確立するために呼び出される関数を設定します。

setCreateOrModifyTopic(Predicate<NewTopic>) - クラス org.springframework.kafka.core のメソッド。KafkaAdmin

検出された NewTopic Bean がこの管理インスタンスによる作成または変更の対象となる場合に true を返す述語を設定します。

setCustomMethodArgumentResolvers(HandlerMethodArgumentResolver...) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

カスタムメソッド引数リゾルバーを KafkaListenerAnnotationBeanPostProcessor デフォルトの空のリストに追加します。

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

DeadLetterPublishingRecovererFactory.DeadLetterPublisherCreator を指定します。たとえば、パブリッシュされたレコードを変更する場合など、デフォルトの代わりに DeadLetterPublishingRecoverer のサブクラスを作成するために使用されます。

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

カスタマイザを設定してデフォルトの DeadLetterPublishingRecoverer をカスタマイズします。

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

デッドレターのトピック名を設定します。

setDefaultContainerFactoryBeanName(String) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

デフォルトで使用する KafkaListenerContainerFactory の名前を設定します。

setDefaultMethod(Method) - クラス org.springframework.kafka.config のメソッド。MultiMethodKafkaListenerEndpoint

デフォルトの方法を設定します。

setDefaultMethod(Method) - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMultiMethod

デフォルトの方法を設定します。

setDefaultReplyTimeout(Duration) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

ReplyingKafkaTemplate.sendAndReceive(ProducerRecord, Duration) 呼び出しで replyTimeout が提供されない場合に使用される応答タイムアウトを設定します。

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

トピックが提供されていない送信メソッドのデフォルトのトピックを設定します。

setDelegates(ProducerListener<K, V>...) - クラス org.springframework.kafka.support のメソッド。CompositeProducerListener

setDeliveryAttemptHeader(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

エラーハンドラーまたはロールバックプロセッサーが DeliveryAttemptAware を実装した後、KafkaHeaders.DELIVERY_ATTEMPT ヘッダーにデータを入力するには、true に設定します。

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

リスナースレッドで致命的なエラーが発生するたびに呼び出すように RunnableSE を設定します。

setEncodeStrings(boolean) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper

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

文字列値のヘッダーを JSON 文字列 ( "..." ) としてエンコードするには true に設定します。デフォルトでは、構成された文字セットを使用して生の文字列値のみがバイト配列に変換されます。

setEncodeStrings(boolean) - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper

文字列値のヘッダーを JSON 文字列 ( "..." ) としてエンコードするには true に設定します。デフォルトでは、構成された文字セットを使用して生の文字列値のみがバイト配列に変換されます。

setEndpointRegistry(KafkaListenerEndpointRegistry) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

作成したエンドポイントを保持し、関連するリスナーコンテナーのライフサイクルを管理する KafkaListenerEndpointRegistry を設定します。

setEndpointRegistry(KafkaListenerEndpointRegistry) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

使用する KafkaListenerEndpointRegistry インスタンスを設定します。

setEosMode(ContainerProperties.EOSMode) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

一度だけのセマンティクスモードを設定します。

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

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

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

setErrorHandlers(Map<Class<? extends Throwable>, CommonErrorHandler>) - クラス org.springframework.kafka.listener のメソッド。CommonDelegatingErrorHandler

デリゲートエラーハンドラーを設定します。デリゲートが既知の順序で検索されるように、LinkedHashMapSE 引数をお勧めします。

setExceptionHeadersCreator(DeadLetterPublishingRecoverer.ExceptionHeadersCreator) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

DeadLetterPublishingRecoverer.ExceptionHeadersCreator 実装を設定して、出力レコードの例外ヘッダーの設定を完全に引き継ぎます。

setExceptionHeadersCreator(DeadLetterPublishingRecoverer.ExceptionHeadersCreator) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

DeadLetterPublishingRecoverer.ExceptionHeadersCreator 実装を設定して、出力レコードの例外ヘッダーの設定を完全に引き継ぎます。

setExplicitShareAcknowledgment(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

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

ContainerProperties.setShareAckMode(ShareAckMode) と ContainerProperties.ShareAckMode.MANUAL を推奨します。

setFailedDeserializationFunction(Function<FailedDeserializationInfo, T>) - クラス org.springframework.kafka.support.serializer のメソッド。ErrorHandlingDeserializer

逆直列化が失敗した場合の代替供給メカニズムを提供します。

setFailIfSendResultIsError(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

true に設定すると、send の結果を待機できるようになり、失敗した場合は例外がスローされます。

setFallbackType(Class<?>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

型対応メッセージコンバーターを使用するときに使用するフォールバック型を設定します。このアダプターは、メソッドから推測された型を判別できません。

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

初期化中にブローカーに接続できない場合にアプリケーションコンテキストのロードに失敗する場合は、true に設定して、トピックを確認 / 追加します。

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

setFixTxOffsets(boolean) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

トランザクションプロデューサーによって生成されたレコードを消費するときに、コンシューマーがパーティションの最後に配置されていると、トランザクションのコミット / ロールバックを示すために使用される疑似レコードや、ロールバックされたレコードが存在する可能性があるために、ラグが誤ってゼロよりも大きく報告されることがありました。

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

Kafka の外部で構成するときに、このデシリアライザーをキーデシリアライザーとして使用する場合は true に設定します。

setGenerateMessageId(boolean) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

作成されたメッセージに対して Message ids を生成します。

setGenerateMessageId(boolean) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

作成されたメッセージに対して Message ids を生成します。

setGenerateTimestamp(boolean) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

生成されたメッセージに対して timestamp を生成します。

setGenerateTimestamp(boolean) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

生成されたメッセージに対して timestamp を生成します。

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

対応するリスナーコンテナーのグループを設定します。

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

グループ ID を設定して、ContainerFactory の group.id プロパティをオーバーライドします。

setGroupId(String) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

このコンテナーのグループ ID を設定します。

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

StreamsBuilderFactoryBean で使用するグループプロトコルを設定します。

setHandlerMethod(HandlerAdapter) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

受信 ConsumerRecord を処理するメソッドを呼び出すために使用する HandlerAdapter を設定します。

setHeaderMapper(KafkaHeaderMapper) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

ヘッダーマッパーを設定してヘッダーをマップします。

setHeaderMapper(KafkaHeaderMapper) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

ヘッダーマッパーを設定してヘッダーをマップします。

setHeaderNamesSupplier(Supplier<DeadLetterPublishingRecoverer.HeaderNames>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

SupplierSE を DeadLetterPublishingRecoverer.HeaderNames に設定します。

setHeaderNamesSupplier(Supplier<DeadLetterPublishingRecoverer.HeaderNames>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

SupplierSE を DeadLetterPublishingRecoverer.HeaderNames に設定します。

setHeaders(Headers) - Method in exception org.springframework.kafka.support.serializer.DeserializationException

ヘッダーを設定します。

setHeadersFunction(BiFunction<ConsumerRecord<?, ?>, Exception, Headers>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

公開されたレコードに追加する追加のヘッダーを取得するために呼び出される関数を設定します。

setHeadersFunction(BiFunction<ConsumerRecord<?, ?>, Exception, Headers>) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

公開されたレコードに追加する追加のヘッダーを取得するために呼び出される関数を設定します。

setHeadersFunction(BiFunction<ConsumerRecord<?, ?>, Exception, Headers>) - クラス org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory

このファクトリによって追加された標準の再試行ヘッダーに加えて、出力レコードに追加のヘッダーを作成する関数を設定します。

setHeaderValue(byte[]) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper.NonTrustedHeaderType

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

setHeaderValue(byte[]) - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper.NonTrustedHeaderType

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

setIdClassMapping(Map<String, Class<?>>) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

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

setIdClassMapping(Map<String, Class<?>>) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

setIdleBeforeDataMultiplier(double) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

少なくとも 1 つのレコードが受信されるまで、ContainerProperties.setIdleEventInterval(Long) にこの値を掛けます。

setIdleBetweenPolls(long) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

Consumer.poll(Duration) 呼び出し間のメインループで使用されるミリ秒単位のスリープ間隔。

setIdleEventInterval(Long) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

アイドルイベント間隔を設定します。設定すると、ポーリングがレコードを返さず、レコードが返されてからこの間隔が経過した場合にイベントが発行されます。

setIdlePartitionEventInterval(Long) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

アイドルパーティションイベント間隔を設定します。設定すると、ポーリングがパーティションのレコードを返さず、レコードが返されてからこの間隔が経過した場合にイベントが発行されます。

setIncludeContents(boolean) - クラス org.springframework.kafka.support のメソッド。LoggingProducerListener

ログメッセージに内容（キーとペイロード）を含めるかどうか。

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

ストリームを作成する前に、カスタマイザーを設定してビルダーやトポロジーを構成します。

setInitialInterval(long) - クラス org.springframework.kafka.support のメソッド。ExponentialBackOffWithMaxRetries

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

false の場合、トランザクションの開始後にインターセプターを呼び出します。

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

存在する場合、観測用のクラスター ID を見つけるために使用される KafkaAdmin を設定します。

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

存在する場合、観測用のクラスター ID を見つけるために使用される KafkaAdmin を設定します。

setKafkaAwareTransactionManager(KafkaAwareTransactionManager<?, ?>) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

トランザクションマネージャーを設定してトランザクションを開始します。ContainerProperties.setTransactionManager(org.springframework.transaction.PlatformTransactionManager) を置き換えます。

setKafkaConsumerProperties(Properties) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

コンシューマーファクトリによって提供されるコンシューマープロパティとマージされるコンシューマープロパティを設定します。ここのプロパティは、コンシューマーファクトリの同じ名前のプロパティよりも優先されます。

setKafkaHeaderMapper(KafkaHeaderMapper) - クラス org.springframework.kafka.listener.adapter のメソッド。ConvertingMessageListener

KafkaHeaderMapper を設定します。

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

KafkaStreamsCustomizer を指定して、StreamsBuilderFactoryBean.start() 中に KafkaStreams インスタンスをカスタマイズします。

setKeyClassIdFieldName(String) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

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

マップキー型情報のヘッダー名を設定します。

setKeyClassIdFieldName(String) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

マップキー型情報のヘッダー名を設定します。

setKeyDeserializer(Deserializer<K>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

キーデシリアライザを設定します。

setKeyDeserializer(Deserializer<K>) - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory

キーデシリアライザを設定します。

setKeyDeserializerSupplier(Supplier<Deserializer<K>>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

キーデシリアライザーのインスタンスを提供するようにサプライヤーを設定します。

setKeyDeserializerSupplier(Supplier<Deserializer<K>>) - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory

キーデシリアライザーのインスタンスを提供するようにサプライヤーを設定します。

setKeySerializer(Serializer<K>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

キーシリアライザを設定します。

setKeySerializerSupplier(Supplier<Serializer<K>>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

キーシリアライザーのインスタンスを提供するようにサプライヤーを設定します。

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

Kafka ストリームを停止するときにコンシューマーがグループを離れるかどうかを指定します。

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

MessageListenerContainer をフェッチしてバックオフするために使用される ListenerContainerRegistry を設定します。

setListenerInfo(byte[]) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

すべてのレコードの KafkaHeaders.LISTENER_INFO ヘッダーに追加される任意の情報を設定します。

setListenerInfo(byte[]) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

レコードヘッダーに挿入するリスナー情報を設定します。

setListenerTaskExecutor(AsyncTaskExecutor) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

コンシューマーをポーリングするスレッドのエグゼキューターを設定します。

setLogContainerConfig(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

この構成をログに記録するように各コンテナーに指示するには、true に設定します。

setLoginModule(String) - クラス org.springframework.kafka.security.jaas のメソッド。KafkaJaasLoginModuleInitializer

setLogLevel(KafkaException.Level) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

setLogLevel(KafkaException.Level) - クラス org.springframework.kafka.listener のメソッド。KafkaExceptionLogLevelAware

このハンドラーによってスローされた例外がログに記録されるレベルを設定します。

setLogRecoveryRecord(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

リカバリレコードと例外をログに記録する場合は、true に設定します。

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

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

このコンテナーが再試行トピック用の場合、メインリスナー ID を設定します。

setMapAllStringsOut(boolean) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

すべての String 値の送信 ヘッダーを byte[] にマップするには、true に設定します。

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

プロデューサーの最大年齢を設定します。トランザクションを使用するときに便利で、非アクティブのためにブローカーが transactional.id を期限切れにする可能性があります。

setMaxContentLogged(int) - クラス org.springframework.kafka.support のメソッド。LoggingProducerListener

キーまたはパスワードのいずれかについてログに記録されるデータの最大量。

setMaxElapsedTime(long) - クラス org.springframework.kafka.support のメソッド。ExponentialBackOffWithMaxRetries

setMaxInterval(long) - クラス org.springframework.kafka.support のメソッド。ExponentialBackOffWithMaxRetries

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

使用するメッセージコンバーターを設定します。

setMessageConverter(RecordMessageConverter) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

MessageConverter を設定します。

setMessageConverter(MessageConverter) - クラス org.springframework.kafka.listener.adapter のメソッド。ConvertingMessageListener

MessageConverter を設定します。

setMessageConverter(MessageConverter) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaMessageHandlerMethodFactory

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor

MessageHandlerMethodFactory を使用して、このプロセッサーによって検出されたエンドポイントを処理するメッセージリスナーを構成するように設定します。

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

MessageHandlerMethodFactory を使用して、このプロセッサーによって検出されたエンドポイントを処理するメッセージリスナーを構成するように設定します。

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

このエンドポイントの呼び出しの管理を担当する InvocableHandlerMethod を構築するために使用する MessageHandlerMethodFactory を設定します。

setMessageListener(Object) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

メッセージリスナーを設定します。MessageListener または AcknowledgingMessageListener である必要があります。

setMessagingConverter(SmartMessageConverter) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

SmartMessageConverter を設定して、レコード値を目的の型に変換します。

setMessagingConverter(SmartMessageConverter) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

spring-messaging SmartMessageConverter を設定して、レコード値を目的の型に変換します。

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

spring-messaging SmartMessageConverter を設定して、レコード値を目的の型に変換します。

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

デフォルトの MessagingMessageConverter で使用するように SmartMessageConverter を設定します。

setMessagingConverter(SmartMessageConverter) - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter

バッチメッセージコンバーターで使用するために SmartMessageConverter を設定します。

setMessagingConverter(SmartMessageConverter) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

デフォルトの MessagingMessageConverter で使用するように SmartMessageConverter を設定します。

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

このエンドポイントによって管理されるメッセージを処理するために呼び出すメソッドを設定します。

setMethods(List<Method>) - クラス org.springframework.kafka.config のメソッド。MultiMethodKafkaListenerEndpoint

メソッドリストを設定します。

setMethods(List<Method>) - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMultiMethod

メソッドリストを設定します。

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

micrometer がクラスパス上にある場合、false に設定すると、micrometer タイマーが無効になります。

setMicrometerEnabled(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

false に設定すると、Micrometer リスナータイマーが無効になります。

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

Micrometer リスナータイマーに追加のタグを設定します。

setMicrometerTags(Map<String, String>) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

Micrometer リスナータイマーに追加のタグを設定します。

setMicrometerTagsProvider(Function<ConsumerRecord<?, ?>, Map<String, String>>) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

コンシューマーレコードに基づいて動的タグを提供する関数を設定します。

setMicrometerTagsProvider(Function<ProducerRecord<?, ?>, Map<String, String>>) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate

プロデューサーレコードに基づいて動的タグを提供する関数を設定します。

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

false に設定すると、構成されたトピックのいずれかがブローカーに存在しない場合でもコンテナーを開始できます。

setMissingTopicsFatal(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

構成されたトピックのいずれかがブローカーに存在しない場合にコンテナーが開始しないようにするには、true に設定します。

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

true に設定すると、現在のトピック構成プロパティが NewTopic Bean のプロパティと比較され、異なる場合は更新されます。

setMonitorInterval(int) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

応答しないコンシューマーのチェック間隔（秒単位）。デフォルトの 30.

setMultiplier(double) - クラス org.springframework.kafka.support のメソッド。ExponentialBackOffWithMaxRetries

setMultiValueHeaderPatterns(String...) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

同じキーにある複数の値ヘッダーを一致させるためのパターンを追加します。

setNoPollThreshold(float) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

最後のポーリング / poll timeout からの時間がこの値を超えると、NonResponsiveConsumerEvent が公開されます。

setObservationConvention(KafkaListenerObservationConvention) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

カスタム KafkaListenerObservationConvention を設定します。

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

カスタム KafkaTemplateObservationConvention を設定します。

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

Micrometer 経由の観測を有効にするには、true に設定します。

setObservationEnabled(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

Micrometer 経由の観測を有効にするには、true に設定します。

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

観測の記録に使用するために ObservationRegistry を構成します。

setObservationRegistry(ObservationRegistry) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringMessageListenerAdapter

フィルタリングされたレコードの観測を停止するには、ObservationRegistry を設定します。

setObservationRegistry(ObservationRegistry) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

可観測性を処理するために ObservationRegistry を設定します。

setObservationRegistry(ObservationRegistry) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

観測の記録に使用するために ObservationRegistry を構成します。

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

オフセットを設定します。

setOffsetAndMetadataProvider(OffsetAndMetadataProvider) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

コミットコールバックに関連付けられたオフセットおよびメタデータプロバイダーを設定します。

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

操作タイムアウトを秒単位で設定します。

setOptions(Map<String, String>) - クラス org.springframework.kafka.security.jaas のメソッド。KafkaJaasLoginModuleInitializer

setPartitionInfoTimeout(Duration) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

検証時にパーティション情報を待つ時間。

setPartitionResolver(BiFunction<ConsumerRecord<?, ?>, String, Integer>) - クラス org.springframework.kafka.retrytopic のメソッド。DeadLetterPublishingRecovererFactory

パブリッシュ先のパーティション番号のリゾルバーを設定します。

setPauseImmediate(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

前のポーリングのすべてのレコードが処理された後ではなく、現在のレコードが処理された後にコンテナーを一時停止するには、true に設定します。

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

使用する phase を指定します。

setPhase(int) - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory

このファクトリによって作成されたコンテナーを起動および停止するフェーズを設定します。

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

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

setPhase(int) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

setPhase(int) - クラス org.springframework.kafka.listener のメソッド。ContainerGroupSequencer

SmartLifecycle.getPhase() を設定してください。

setPhase(int) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

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

プロデューサー自体を閉じるのではなく、ファクトリを介してプロデューサーを物理的に閉じるときに待機する時間（DefaultKafkaProducerFactory.reset()、#closeProducerFor(String)、DefaultKafkaProducerFactory.closeThreadBoundProducer() が呼び出されたとき）。

setPollTimeout(long) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

レコードを待機しているコンシューマーでブロックする最大時間を設定します。

setPollTimeoutWhilePaused(Duration) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

一時停止中に使用するポーリングタイムアウトを設定します。通常は pollTimeout よりも小さい数値です。

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

このテンプレートにプロデューサーインターセプターを設定します。

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

Kafka が送信操作を確認したときに呼び出される ProducerListener を設定します。

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

すべてのクライアントで共有されるシングルトンではなく、スレッドごとにプロデューサーを作成するには、true に設定します。

setProducerRecordFormatter(Function<ProducerRecord<?, ?>, String>) - Static method in class org.springframework.kafka.support.KafkaUtils

ProducerRecord をログに記録するためのフォーマッターを設定します。

setRawMappedHeaders(Map<String, Boolean>) - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper

ヘッダーが変換を実行しないように設定します (送信用の String から byte[] を除く)。

setRawRecordHeader(boolean) - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter

true に設定すると、生の List<ConsumerRecord<?, ?>> がヘッダー KafkaHeaders.RAW_DATA として追加されます。

setRawRecordHeader(boolean) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

true に設定すると、生の ConsumerRecord がヘッダー KafkaHeaders.RAW_DATA として追加されます。

setReclassifyOnExceptionChange(boolean) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

以前の失敗と異なる場合に例外を再分類しないようにするには、false に設定します。

setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

レコードフィルター戦略を設定します。

setRecordFilterStrategy(RecordFilterStrategy<? super K, ? super V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

RecordFilterStrategy 実装を設定します。

setRecordInterceptor(RecordInterceptor<K, V>) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

レコードリスナーを呼び出す前に呼び出されるインターセプターを設定します。

setRecordInterceptor(RecordInterceptor<K, V>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

リスナーを呼び出す前にインターセプターが呼び出されるように設定します。

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

レコードリスナーに動的な引数の型の一致が必要な場合に使用するメッセージコンバーターを設定します。

setRecordObservationsInBatch(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

バッチで個々のレコードの監視を有効にするかどうかを設定します。

setRecoveryCallback(Function<RetryException, T>) - クラス org.springframework.kafka.support.serializer のメソッド。RetryingDeserializer

再試行回数が尽きたときに実行するリカバリコールバックを設定します。

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

オフセットが現在の位置を基準にしているかどうかを設定します。

setRemoveTypeHeaders(boolean) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

逆直列化後に型情報ヘッダーを保持するには、false に設定します。

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

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

逆直列化後に型情報ヘッダーを保持するには、false に設定します。

setReplyErrorChecker(Function<ConsumerRecord<?, ?>, Exception>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

サーバーから返されたエラーの応答を調べる関数を設定します。

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

応答メッセージを作成するときに呼び出される設定者を設定します。

setReplyHeadersConfigurer(ReplyHeadersConfigurer) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

応答メッセージを作成するときに呼び出される設定者を設定します。

setReplyHeadersConfigurer(ReplyHeadersConfigurer) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

応答メッセージを作成するときに呼び出される設定者を設定します。

setReplyPartitionHeaderName(String) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

応答パーティションのカスタムヘッダー名を設定します。

setReplyTemplate(KafkaTemplate<?, ?>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

返信の送信に使用する KafkaTemplate を設定します。

setReplyTemplate(KafkaTemplate<?, ?>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

返信の送信に使用する KafkaTemplate を設定します。

setReplyTemplate(KafkaTemplate<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

メソッド呼び出しからの結果を送信するために使用するテンプレートを設定します。

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

メソッド呼び出しの結果を送信するトピックを設定します。

setReplyTopicHeaderName(String) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

返信トピックのカスタムヘッダー名を設定します。

setResetStateOnExceptionChange(boolean) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

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

例外が同じレコードの以前の失敗とは異なる型である場合、再試行 BackOff をリセットするには、true に設定します。

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

false に設定すると、回復が失敗したときに BackOff サイクルを繰り返す代わりに、次の試行ですぐに回復を試みます。

setRestartAfterAuthExceptions(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

コンテナー (またはすべての子コンテナー) によって認証例外が検出された場合にコンテナーを自動的に再始動するには、true に設定します。

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

RetryTopicHeaders の最後の値のみを保持するには、false に設定します。デフォルトでは true で、レコードがトピック間を遷移するときにすべての値が保持されます。

setRetainExceptionHeader(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

Java 直列化 DeserializationException ヘッダーを保持するには、true に設定します。

setRetainExceptionHeader(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

Java 直列化 DeserializationException ヘッダーを保持するには、true に設定します。

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

ブロック再試行を構成するときに、標準の致命的な例外を再試行不可として保持するには、true に設定します。

setRetryListeners(RetryListener...) - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor

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

1 つ以上の RetryListener を設定して、再試行とリカバリの通知を受信します。

setRetryTemplate(RetryTemplate) - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsInteractiveQueryService

エンドユーザーが提供するカスタム RetryTemplate。

setReturnPartialOnTimeout(boolean) - クラス org.springframework.kafka.requestreply のメソッド。AggregatingReplyingKafkaTemplate

true に設定すると、リクエストがタイムアウトしたときに部分的な結果が返されます。

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

setRunning(boolean) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

setScheduler(TaskScheduler) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

モニター間隔で使用されるスケジューラー。

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

true (デフォルト) の場合、エラーハンドラーは失敗したレコードや残りのレコードに対してシークを実行し、次のポーリングで再配信されます。

setSendFuture(CompletableFuture<SendResult<K, V>>) - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyFuture

setShareAckMode(ContainerProperties.ShareAckMode) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

共有コンシューマーコンテナーの確認応答モードを設定します。

setShareAcknowledgmentTimeout(Duration) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

ContainerProperties.ShareAckMode.MANUAL モードでの共有確認応答のタイムアウトを設定します。

setShareConsumer(boolean) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

setShareConsumerRecordRecoverer(ShareConsumerRecordRecoverer) - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory

このファクトリで作成されるすべてのコンテナーに使用するコンテナーに ShareConsumerRecordRecoverer を設定します。

setShareConsumerRecordRecoverer(ShareConsumerRecordRecoverer) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

リスナーが例外をスローしたときに使用する ShareConsumerRecordRecoverer を設定します。

setSharedReplyTopic(boolean) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

複数のテンプレートが返信に同じトピックを使用している場合は、true に設定します。

setShutdownTimeout(long) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

コンテナーをシャットダウンするためのタイムアウトを設定します。

setSkipSameTopicFatalExceptions(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

このクラスの分類によって例外が致命的である場合でも、レコードを同じトピックに転送する場合は、false に設定します。

setSplitIterables(boolean) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint

IterableSE 応答値を個別のレコードに分割することを無効にするには、false に設定します。

setSplitIterables(boolean) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

IterableSE 応答値を個別のレコードに分割しないようにするには、false に設定します。

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

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

setStopContainerAbnormally(boolean) - クラス org.springframework.kafka.listener のメソッド。CommonContainerStoppingErrorHandler

コンテナーを正常に停止するには、false に設定します。

setStopContainerWhenFenced(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

true に設定すると、ProducerFencedException がスローされたときにコンテナーが停止します。

setStopImmediate(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

現在のレコードを処理した後（stop() が呼び出されたとき）にコンテナーを停止するには、true に設定します。

setStopLastGroupWhenIdle(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerGroupSequencer

true に設定すると、最終グループのコンテナーがアイドル状態になったときに停止します。

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

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

このファクトリでストリーム構成 PropertiesSE を設定します。

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

StreamsUncaughtExceptionHandler を設定します。

setStripPreviousExceptionHeaders(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

現在の例外のヘッダーだけでなく、以前の例外ヘッダーも保持するには、false に設定します。

setStripPreviousExceptionHeaders(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager

現在の例外のヘッダーだけでなく、以前の例外ヘッダーも保持するには、false に設定します。

setSubBatchPerPartition(Boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

バッチメッセージリスナーを使用する場合、パーティションごとにレコードをディスパッチするか（トランザクションが使用されている場合はサブバッチごとにトランザクションを使用）、poll() が受信したバッチ全体をディスパッチします。

setSyncCommits(boolean) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

コンテナーがコミットを担当するときに consumer.commitSync() または commitAsync() を呼び出すかどうかを設定します。

setSyncCommitTimeout(Duration) - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties

commitSync 操作のタイムアウトを設定します (ConsumerProperties.isSyncCommits() の場合)。

setSyncCommitTimeout(Duration) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

commitSync 操作のタイムアウトを設定します (ConsumerProperties.isSyncCommits() の場合)。

setSyncShareCommits(boolean) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

共有コンシューマー確認コミットに commitSync() または commitAsync() のどちらを使用するかを設定します。

setTaskScheduler(TaskScheduler) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

setThreadNameSupplier(Function<MessageListenerContainer, String>) - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory

コンシューマースレッド名を変更するために使用する関数を設定します。

setThreadNameSupplier(Function<MessageListenerContainer, String>) - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer

コンシューマースレッド名を変更するために使用する関数を設定します。

setThrowIfNoDestinationReturned(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

宛先リゾルバー関数が null TopicPartition を返した場合に例外をスローするには、true に設定します。

setTimeoutBuffer(long) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

Kafka プロデューサーの前にタイムアウトにならないように、プロデューサー構成 delivery.timeout.ms プロパティに追加するミリ秒数を設定します。

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

Admin.describeTopics(Collection) 結果先物が完了するまで待機する時間。

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

使用する topicPartitions を設定します。

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

使用するトピックパターンを設定します。

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

使用するトピックを設定します。

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

再試行トピック名 TopicSuffixingStrategy を構成します。

setTransactionDefinition(TransactionDefinition) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

プロパティを使用してトランザクション定義を設定します（例:

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

ProducerConfig.TRANSACTIONAL_ID_CONFIG 構成のプレフィックスを設定します。

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

トランザクション ID プレフィックスを設定して、プロデューサーファクトリのプレフィックスをオーバーライドします。

setTransactionIdPrefix(String) - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager

トランザクション ID プレフィックスを設定して、プロデューサーファクトリのプレフィックスをオーバーライドします。

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

トランザクションサフィックス戦略を設定します。

setTransactionManager(PlatformTransactionManager) - クラス org.springframework.kafka.listener のメソッド。ContainerProperties

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

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

この一致でネストされた原因を走査して一致する例外の存在を確認するかどうかを指定します。

setTypeFunction(BiFunction<byte[], Headers, JavaType>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

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

デシリアライズするデータとヘッダーを受け取り、JavaType を返す BiFunctionSE を設定します。

setTypeFunction(BiFunction<byte[], Headers, JavaType>) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

デシリアライズするデータとヘッダーを受け取り、JavaType を返す BiFunctionSE を設定します。

setTypeMapper(Jackson2JavaTypeMapper) - クラス org.springframework.kafka.support.converter のメソッド。JsonMessageConverter

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

カスタマイズされた型マッパーを設定します。

setTypeMapper(Jackson2JavaTypeMapper) - クラス org.springframework.kafka.support.converter のメソッド。MappingJacksonParameterizedConverter

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

カスタマイズされた型マッパーを設定します。

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

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

カスタマイズされた型マッパーを設定します。

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

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

カスタマイズされた型マッパーを設定します。

setTypeMapper(JacksonJavaTypeMapper) - クラス org.springframework.kafka.support.converter のメソッド。JacksonJsonMessageConverter

カスタマイズされた型マッパーを設定します。

setTypeMapper(JacksonJavaTypeMapper) - クラス org.springframework.kafka.support.converter のメソッド。MappingJacksonJsonParameterizedConverter

カスタマイズされた型マッパーを設定します。

setTypeMapper(JacksonJavaTypeMapper) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

カスタマイズされた型マッパーを設定します。

setTypeMapper(JacksonJavaTypeMapper) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer

カスタマイズされた型マッパーを設定します。

setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper

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

setTypePrecedence(Jackson2JavaTypeMapper.TypePrecedence) - インターフェース org.springframework.kafka.support.mapping のメソッド。Jackson2JavaTypeMapper

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

メッセージプロパティで型情報を評価するための優先順位を設定します。

setTypePrecedence(JacksonJavaTypeMapper.TypePrecedence) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

setTypePrecedence(JacksonJavaTypeMapper.TypePrecedence) - インターフェース org.springframework.kafka.support.mapping のメソッド。JacksonJavaTypeMapper

メッセージプロパティで型情報を評価するための優先順位を設定します。

setTypeResolver(JacksonJsonTypeResolver) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

デシリアライズするデータとヘッダーを受け取り、JavaType を返す JacksonJsonTypeResolver を設定します。

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

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

デシリアライズするデータとヘッダーを受け取り、JavaType を返す JsonTypeResolver を設定します。

setUntrustedType(String) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper.NonTrustedHeaderType

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

setUntrustedType(String) - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper.NonTrustedHeaderType

setupBackoffAwareMessageListenerAdapter(ConcurrentMessageListenerContainer<?, ?>) - クラス org.springframework.kafka.retrytopic のメソッド。ListenerContainerFactoryConfigurer

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

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

setupListenerContainer(MessageListenerContainer, MessageConverter) - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint

このエンドポイントで定義されたモデルを使用して、指定されたメッセージリスナーコンテナーをセットアップします。

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

setupMessageListener(Object) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

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

使用するメッセージリスナーを設定します。

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

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

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

Consumer を含む囲まれた操作の全期間にわたって利用可能になるスレッドバウンドリソースをセットアップするために呼び出します。

setUseForKey(boolean) - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper

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

デフォルトのキー型 クラスを使用するように TypeMapper を設定します。

setUseForKey(boolean) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper

デフォルトのキー型 クラスを使用するように TypeMapper を設定します。

setUseTypeHeaders(boolean) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

false に設定すると、ヘッダーの型情報が無視され、代わりに構成済みのターゲット型が使用されます。

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

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

false に設定すると、ヘッダーの型情報が無視され、代わりに構成済みのターゲット型が使用されます。

setUseTypeMapperForKey(boolean) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer

キー型ヘッダーを使用するようにデフォルトの JacksonJavaTypeMapper を構成します。

setUseTypeMapperForKey(boolean) - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer

キー型ヘッダーを使用するようにデフォルトの Jackson2JavaTypeMapper を構成します。

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

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

キー型ヘッダーを使用するようにデフォルトの Jackson2JavaTypeMapper を構成します。

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

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

キー型ヘッダーを使用するようにデフォルトの Jackson2JavaTypeMapper を構成します。

setValidator(Validator) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar

デフォルトのメッセージハンドラーファクトリを使用する場合に使用するバリデーターを設定します。

setValidator(Validator) - クラス org.springframework.kafka.config のメソッド。MultiMethodKafkaListenerEndpoint

ペイロードバリデーターを設定します。

setValidator(Validator) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaMessageHandlerMethodFactory

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

逆直列化が成功した後にオブジェクトを検証するためのバリデーターを設定します。

setValueDeserializer(Deserializer<V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

値デシリアライザーを設定します。

setValueDeserializer(Deserializer<V>) - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory

値デシリアライザーを設定します。

setValueDeserializerSupplier(Supplier<Deserializer<V>>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory

値デシリアライザーのインスタンスを提供するようにサプライヤーを設定します。

setValueDeserializerSupplier(Supplier<Deserializer<V>>) - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory

値デシリアライザーのインスタンスを提供するようにサプライヤーを設定します。

setValueSerializer(Serializer<V>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

値シリアライザーを設定します。

setValueSerializerSupplier(Supplier<Serializer<V>>) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory

値シリアライザーのインスタンスを提供するようにサプライヤーを設定します。

setVerifyPartition(boolean) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

false に設定すると、パーティションの検証が無効になります。

setWaitForSendResultTimeout(Duration) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer

メッセージの送信を待機する最小時間を設定します。

ShareAcknowledgment - Interface in org.springframework.kafka.support

共有グループを使用するときにレコードの配信を確認するためのハンドル。

shareConsumerFactory - Variable in class org.springframework.kafka.listener.AbstractShareKafkaMessageListenerContainer

コンシューマーインスタンスを作成するために使用される共有コンシューマーファクトリ。

ShareConsumerFactory< K , V > - Interface in org.springframework.kafka.core

Kafka キューサポート用の ShareConsumer インスタンスを生成する戦略。

ShareConsumerFactory.Listener < K、V > - org.springframework.kafka.core のインターフェース

共有コンシューマーライフサイクルイベントのリスナー。

ShareConsumerRecordRecoverer - Interface in org.springframework.kafka.listener

共有コンシューマーレコードの処理が失敗した場合に、確認アクションを決定するための戦略インターフェース。

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

株式利用者が利用を停止した際に発行されるイベント。

ShareConsumerStoppingEvent(Object, Object, ShareConsumer<?, ?>) - クラス org.springframework.kafka.event. ShareConsumerStoppingEvent のコンストラクター

指定されたソース、コンテナー、共有コンシューマーを使用してインスタンスを構築します。

ShareKafkaListenerContainerFactory< K , V > - Class in org.springframework.kafka.config

Kafka の共有コンシューマーモデル用の ShareKafkaMessageListenerContainer インスタンスを作成するための KafkaListenerContainerFactory 実装。

ShareKafkaListenerContainerFactory(ShareConsumerFactory<K, V>) - クラス org.springframework.kafka.config. ShareKafkaListenerContainerFactory のコンストラクター

提供されたコンシューマーファクトリを使用してインスタンスを構築します。

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

Java ShareConsumer を使用してコンシューマーコンテナーを共有します。

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

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

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

構成可能な HandlerAdapter を呼び出す MessageListener アダプター。リスナーが共有グループから個々のメッセージを受信できるようにファクトリが構成されている場合に使用されます。

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

shouldCopy(String, Object) - インターフェース org.springframework.kafka.listener.adapter のメソッド。ReplyHeadersConfigurer

ヘッダーを応答メッセージにコピーする必要がある場合は true を返します。

shouldRetryOn(Integer, Throwable) - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic

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

シンプル。

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

ヘッダーを直接マップする単純なヘッダーマッパー。送信の場合、byte[] ヘッダーのみがマップされます。受信の場合、ヘッダーは変更されずに byte[] としてマップされます。

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

送信ヘッダーのデフォルトのオブジェクトマッパーとデフォルトのヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。

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

デフォルトのオブジェクトマッパーと送信ヘッダー用に提供されたヘッダーパターンを使用してインスタンスを構築します。すべての受信ヘッダーがマップされます。

SimplePatternBasedHeaderMatcher(String) - クラス org.springframework.kafka.support のコンストラクター。AbstractKafkaHeaderMapper.SimplePatternBasedHeaderMatcher

SINGLE_TOPIC - Enum constant in enum class org.springframework.kafka.retrytopic.SameIntervalTopicReuseStrategy

同じ間隔で連続して試行するための単一の再試行トピックを使用します。

SingleRecordHeader(String, byte[]) - クラス org.springframework.kafka.listener のコンストラクター。DeadLetterPublishingRecoverer.SingleRecordHeader

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

SingleRecordHeader(ByteBuffer, ByteBuffer) - クラス org.springframework.kafka.listener のコンストラクター。DeadLetterPublishingRecoverer.SingleRecordHeader

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

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

source レコードコンポーネントの値を返します。

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

false で戻り値の型が IterableSE の場合、各要素の個々のレコードではなく、単一の応答レコードの値として結果が返されます。

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

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

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

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

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

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

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

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

start() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

start() - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder

タイマーを開始します。

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

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

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

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

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

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

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

stop() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

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

コンテナーを停止します。

stop(Runnable) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry

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

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

stop(Runnable) - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer

stop(Runnable) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate

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

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

MessageListenerContainer.isInExpectedState() が false を返すように、いくつかの例外の後でコンテナーを停止します。

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

コンテナーが実行を継続している限り、必要なタイムアウトの間スリープします。

streamsAdded(String, KafkaStreams) - インターフェース org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean.Listener

新しい KafkaStreams が作成されました。

streamsAdded(String, KafkaStreams) - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsMicrometerListener

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

StreamsBuilder インスタンスの AbstractFactoryBean と内部 KafkaStreams インスタンスのライフサイクルコントロール。

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

構成なしでファクトリを作成するデフォルトのコンストラクター PropertiesSE。

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

提供されたストリーム構成でインスタンスを構築します。

StreamsBuilderFactoryBean(KafkaStreamsConfiguration, CleanupConfig) - クラス org.springframework.kafka.config. StreamsBuilderFactoryBean のコンストラクター

提供されたストリーム構成でインスタンスを構築し、構成をクリーンアップします。

StreamsBuilderFactoryBean.Listener - org.springframework.kafka.config のインターフェース

KafkaStreams が追加または削除されるたびに呼び出されます。

StreamsBuilderFactoryBeanConfigurer - Interface in org.springframework.kafka.config

StreamsBuilderFactoryBean のコンフィギュレーター。

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

Kafka ストリームのテストプロパティを設定します。

streamsRemoved(String, KafkaStreams) - インターフェース org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean.Listener

既存の KafkaStreams が削除されました。

streamsRemoved(String, KafkaStreams) - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsMicrometerListener

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

出力に Jackson 3 - 文字列、入力に文字列、バイト、byte[] に基づく JSON メッセージコンバーター。

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

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

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

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

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

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

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

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

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

StringOrBytesSerializer - org.springframework.kafka.support.serializer のクラス

byte[]、Bytes、StringSE を処理できるシリアライザー。

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

success(Object) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder

成功を記録します。

success(Object, Object) - Method in class org.springframework.kafka.support.micrometer.MicrometerHolder

成功を記録します。

success(ConsumerRecord<K, V>, Consumer<K, V>) - クラス org.springframework.kafka.listener のメソッド。CompositeRecordInterceptor

success(ConsumerRecord<K, V>, Consumer<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。RecordInterceptor

リスナーが正常に終了した後に呼び出されます。

success(ConsumerRecords<K, V>, Consumer<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。BatchInterceptor

リスナーが正常に終了した後に呼び出されます。

success(ConsumerRecords<K, V>, Consumer<K, V>) - クラス org.springframework.kafka.listener のメソッド。CompositeBatchInterceptor

SUFFICIENT - Enum constant in enum class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag

十分 - LoginModule は成功する必要はありません。

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

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

新しい DLT の名前を構築するときに使用されるサフィックス拡張子。

SUFFIX_WITH_DELAY_VALUE - Enum constant in enum class org.springframework.kafka.retrytopic.TopicSuffixingStrategy

トピックのサフィックスは、トピックの遅延値です。

SUFFIX_WITH_INDEX_VALUE - Enum constant in enum class org.springframework.kafka.retrytopic.TopicSuffixingStrategy

再試行トピックのインデックスでトピックをサフィックスします。

Suffixer - Class in org.springframework.kafka.support

文字列をサフィックスするユーティリティクラス。

Suffixer(String) - Constructor for class org.springframework.kafka.support.Suffixer

SuffixingRetryTopicNamesProvider(DestinationTopic.Properties) - クラス org.springframework.kafka.retrytopic のコンストラクター。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider

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

各名前に接尾辞を追加する再試行およびデッドレターの命名処理。

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

SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider - org.springframework.kafka.retrytopic のクラス

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

再試行トピック名の末尾に序数のインデックス値を付けるように構成します。

supportsContext(Observation.Context) - Method in interface org.springframework.kafka.support.micrometer.KafkaListenerObservationConvention

supportsContext(Observation.Context) - Method in interface org.springframework.kafka.support.micrometer.KafkaTemplateObservationConvention

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

supportsParameter(MethodParameter) - クラス org.springframework.kafka.listener.adapter のメソッド。ContinuationHandlerMethodArgumentResolver