インデックス

A B C D E F G H I J K L M N O P R S T U V W
すべてのクラスとインターフェース | すべてのパッケージ | 定数フィールド値 | 連載形式

G

generateValues() - クラス org.springframework.kafka.retrytopic のメソッド。BackOffValuesGenerator
GenericMessageListener< T > - Interface in org.springframework.kafka.listener
リスナーのトップレベルインターフェース。
GenericMessageListenerContainer< K , V > - Interface in org.springframework.kafka.listener
一般的なメッセージリスナーコンテナー。パラメーターを追加します。
get() - Method in class org.springframework.kafka.core.ABSwitchCluster
get() - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyTypedMessageFuture
get(long, TimeUnit) - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyTypedMessageFuture
getAckCount() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getAckMode() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
このエンドポイントのコンテナーの ackMode を返します。
getAckMode() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの ackMode を返します。明示的に設定されていない場合は null を返します。
getAckMode() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getAcknowledgementCommitCallback() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
確認コミットコールバックを取得します。
getAckTime() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getAdminConfig() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin
getAdviceChain() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
リスナー Advice の チェーン。
getAfterRollbackProcessor() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
現在構成されている AfterRollbackProcessor を返します。
getAllListenerContainers() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
このレジストリによって管理されているインスタンスと、アプリケーションコンテキストで Bean として宣言されているインスタンスを含むすべての MessageListenerContainer インスタンスを返します。
getAllListenerContainers() - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
このレジストリによって管理されているインスタンスと、アプリケーションコンテキストで Bean として宣言されているインスタンスを含むすべての MessageListenerContainer インスタンスを返します。
getApplicationContext() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getApplicationContext() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
getApplicationEventPublisher() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
イベントの発行元を取得します。
getApplicationEventPublisher() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
イベントの発行元を取得します。
getAssignedPartitions() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer
getAssignedPartitions() - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer
明示的にまたは Kafka によって、このコンテナーに現在割り当てられている TopicPartition を返します。まだ割り当てられていない場合は null になる可能性があります。
getAssignedPartitions() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
このコンテナーに割り当てられたトピック / パーティションを返します。
getAssignedReplyTopicPartitions() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate
応答するリスナーコンテナーに割り当てられたトピック / パーティションを返します。
getAssignmentCommitOption() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getAssignmentsByClientId() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer
getAssignmentsByClientId() - クラス org.springframework.kafka.listener のメソッド。KafkaMessageListenerContainer
getAssignmentsByClientId() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
client.id によって、このコンテナーに割り当てられたトピック / パーティションを返します。
getAuthExceptionRetryInterval() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
認証 / 認可の再試行間隔を取得します。
getAutoStartup() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getAutoStartup() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントのコンテナーの autoStartup を返します。
getBatchInterceptor() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory
構成されている場合は、変更のために BatchInterceptor を取得します。
getBatchInterceptor() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
構成されている場合は、変更のために BatchInterceptor を取得します。
getBatchListener() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
このエンドポイントの現在のバッチリスナーフラグを返します。明示的に設定されていない場合は null を返します。
getBatchListener() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの現在のバッチリスナーフラグを返します。明示的に設定されていない場合は null を返します。
getBatchMessageConverter() - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter
Message を変換できるようにして、このリスナーの BatchMessagingMessageConverter を返します。
getBatchToRecordAdapter() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getBean() - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint
getBean() - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler
このハンドラーの Bean を返します。
getBean() - クラス org.springframework.kafka.listener.adapter のメソッド。HandlerAdapter
getBean(String, Class<T>) - クラス org.springframework.kafka.listener のメソッド。AbstractKafkaBackOffManagerFactory
getBeanExpressionContext() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getBeanFactory() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getBeanName() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
Bean 名を返します。
getBeanName() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
Bean 名を返します。
getBeanName() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext
テンプレートの Bean 名を返します。
getBeanResolver() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getBlockingRetryDeliveryAttempt() - クラス org.springframework.kafka.support のメソッド。KafkaMessageHeaderAccessor
ブロック配信試行ヘッダーが存在する場合は、ヘッダー値にアクセスします。
getBootstrapServers() - クラス org.springframework.kafka.core のメソッド。KafkaResourceFactory
getBroker() - Static method in class org.springframework.kafka.test.condition.EmbeddedKafkaCondition
getBrokersAsString() - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker
ブートストラップサーバーのアドレスを文字列として取得します。
getBrokersAsString() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker
getCache() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getCache(String) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getCallbacksAndTopics() - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware
現在登録されているコールバックとそれに関連する TopicPartition を返します。
getCharset() - クラス org.springframework.kafka.support のメソッド。AbstractKafkaHeaderMapper
getCharset() - クラス org.springframework.kafka.support.serializer のメソッド。ParseStringDeserializer
構成された文字セットを取得します。
getCharset() - クラス org.springframework.kafka.support.serializer のメソッド。ToStringSerializer
構成された文字セットを取得します。
getClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
使用すべきではありません。
getClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper
getClassLoader() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
使用すべきではありません。
getClassLoader() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper
getClientId() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
クライアント ID を返します。
getClientId() - クラス org.springframework.kafka.listener のメソッド。ShareKafkaMessageListenerContainer
コンシューマー向けに client.id を取得します。
getClientId() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
クライアント ID を返します。
getClientIdPrefix() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getClientIdPrefix() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
コンテナーのクライアント ID プレフィックスを返します。並行性が使用される場合、一意の ID を提供するために "-n" が接尾辞として付けられます。
getClientIdPrefix(KafkaListenerEndpoint) - インターフェース org.springframework.kafka.retrytopic のメソッド。RetryTopicNamesProviderFactory.RetryTopicNamesProvider
エンドポイントの clientId プレフィックスをオーバーライドする clientId プレフィックスを返します。
getClientIdPrefix(KafkaListenerEndpoint) - クラス org.springframework.kafka.retrytopic のメソッド。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getCluster() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker
getClusterId() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin
clusterId プロパティを取得します。
getCommitCallback() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
コミットコールバックを返します。
getCommitLogLevel() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
オフセットコミットをログに記録するレベル。
getCommitRetries() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
true に設定された ConsumerProperties.setSyncCommits(boolean) を使用しているときに、コンシューマーによって RetriableCommitFailedException がスローされたときに許可される再試行の回数。
getCommonErrorHandler() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
CommonErrorHandler を取得します。
getConcurrency() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getConcurrency() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントのコンテナーの同時実行性を返します。
getConcurrency() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer
getConcurrency() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfiguration
getConfigurationProperties() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory
このファクトリの構成マップへの変更不可能な参照を返します。
getConfigurationProperties() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory
getConfigurationProperties() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
このファクトリの構成マップへの変更不可能な参照を返します。
getConfigurationProperties() - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory
getConfigurationProperties() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin
getConfigurationProperties() - インターフェース org.springframework.kafka.core のメソッド。KafkaAdminOperations
この管理者の構成の変更不可能なコピーを取得します。
getConfigurationProperties() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
このファクトリの構成マップへの変更不可能な参照を返します。
getConfigurationProperties() - インターフェース org.springframework.kafka.core のメソッド。ShareConsumerFactory
このファクトリの構成マップへの変更不可能な参照を返します。
getConfigurationProperties() - クラス org.springframework.kafka.mock のメソッド。MockConsumerFactory
getConsumer() - クラス org.springframework.kafka.event のメソッド。ConsumerStoppingEvent
getConsumer() - クラス org.springframework.kafka.event のメソッド。ListenerContainerIdleEvent
コンシューマーを取得します。
getConsumer() - クラス org.springframework.kafka.event のメソッド。ListenerContainerNoLongerIdleEvent
コンシューマーを取得します。
getConsumer() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionIdleEvent
コンシューマーを取得します。
getConsumer() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionNoLongerIdleEvent
コンシューマーを取得します。
getConsumer() - クラス org.springframework.kafka.event のメソッド。NonResponsiveConsumerEvent
コンシューマーを取得します。
getConsumer() - クラス org.springframework.kafka.event のメソッド。ShareConsumerStoppingEvent
共有コンシューマーを返します。
getConsumerFactory() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory
getConsumerForTimingAdjustment() - クラス org.springframework.kafka.listener のメソッド。KafkaConsumerBackoffManager.Context
getConsumerGroup() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Original
コンシューマーグループのヘッダー名。
getConsumerGroupId() - Static method in class org.springframework.kafka.support.KafkaUtils
このスレッドにバインドされているコンシューマーのグループ ID を取得します。
getConsumerProperties() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getConsumerProperties() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
コンシューマーファクトリによって提供されるコンシューマープロパティとマージされるコンシューマープロパティを取得します。ここのプロパティは、コンシューマーファクトリの同じ名前のプロパティよりも優先されます。
getConsumerRebalanceListener() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
リバランスリスナーを返します。
getConsumerStartTimeout() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getContainer(Class<T>) - クラス org.springframework.kafka.event のメソッド。KafkaEvent
イベントが公開されたコンテナーを取得します。これは、イベントを発行したソースが子コンテナーである場合は親コンテナーになり、それ以外の場合はソース自体になります。
getContainerFor(String, int) - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer
getContainerFor(String, int) - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
このコンテナーに子コンテナーがある場合は、トピック / パーティションが割り当てられている子コンテナーを返します。
getContainerPostProcessor() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getContainerPostProcessor() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの ContainerPostProcessor を返します。明示的に設定されていない場合は null を返します。
getContainerProperties() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory
このファクトリのプロパティテンプレートを取得します。必要に応じてプロパティを設定すると、エンドポイントの最終的なプロパティインスタンスにコピーされます。
getContainerProperties() - クラス org.springframework.kafka.config のメソッド。ShareKafkaListenerContainerFactory
ファクトリレベルのコンテナープロパティを取得します - 必要に応じてプロパティを設定すると、このファクトリによって作成された各リスナーコンテナーインスタンスにコピーされます。
getContainerProperties() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getContainerProperties() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
getContainerProperties() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
このコンテナーのコンテナープロパティを返します。
getContainers() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer
このコンテナーによって作成された KafkaMessageListenerContainer のリストを返します。
getContentClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
使用すべきではありません。
getContentClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper
getContext() - クラス org.springframework.kafka.streams のメソッド。HeaderEnricherProcessor.Container
getContextualName(KafkaRecordReceiverContext) - クラス org.springframework.kafka.support.micrometer のメソッド。KafkaListenerObservation.DefaultKafkaListenerObservationConvention
getContextualName(KafkaRecordSenderContext) - クラス org.springframework.kafka.support.micrometer のメソッド。KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
getCorrelationHeaderName() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate
相関ヘッダー名を返します。
getCorrelationId() - クラス org.springframework.kafka.requestreply のメソッド。CorrelationKey
getCreateOrModifyTopic() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin
NewTopic を作成または変更するかどうかを決定するために使用される述語を返します。
getCurrentKafkaStreamsApplicationHostInfo() - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsInteractiveQueryService
この Kafka ストリームアプリケーションが実行されている現在の HostInfo を取得します。
getCurrentOffset(String, String, String, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
提供されたグループ / トピック / パーティションの現在のオフセットとメタデータを取得します。
getCurrentOffset(AdminClient, String, String, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
提供されたグループ / トピック / パーティションの現在のオフセットとメタデータを取得します。
getCustomMethodArgumentResolvers() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar
HandlerMethodArgumentResolver のリストを返します。
getData() - Method in exception org.springframework.kafka.support.serializer.DeserializationException
デシリアライズに失敗したデータ(値またはキー)を取得します。
getData() - クラス org.springframework.kafka.support.serializer のメソッド。FailedDeserializationInfo
getDeadLetterTopicName() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
デッドレターのトピック名を取得します。
getDefaultMethod() - クラス org.springframework.kafka.config のメソッド。MultiMethodKafkaListenerEndpoint
デフォルトのメソッドを取得します。
getDefaultMethod() - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMultiMethod
デフォルトのメソッドを返します。
getDefaultPredicate(Collection<T>, Collection<T>) - クラス org.springframework.kafka.support のメソッド。AllowDenyCollectionManager
getDefaultReplyTimeout() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate
ReplyingKafkaTemplate.sendAndReceive(ProducerRecord, Duration) 呼び出しで replyTimeout が提供されない場合に使用される応答タイムアウトを返します。
getDefaultReplyTopicExpression() - Static method in class org.springframework.kafka.listener.adapter.AdapterUtils
SendTo 値が存在しない場合、デフォルトの式を返します。
getDefaultTopic() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
トピックが提供されない送信メソッドのデフォルトのトピック。
getDelegate() - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractDelegatingMessageListenerAdapter
getDelegate() - クラス org.springframework.kafka.listener.adapter のメソッド。ConvertingMessageListener
getDelegate() - インターフェース org.springframework.kafka.listener のメソッド。DelegatingMessageListener
代理人を返します。
getDelegates() - クラス org.springframework.kafka.support のメソッド。CompositeProducerListener
getDestination() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext
宛先トピックを返します。
getDestinationDelay() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic
getDestinationName() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic
getDestinationPartitions() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic
getDestinationTimeout() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic
getDestinationTopicByName(String, String) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver
getDestinationTopicByName(String, String) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicContainer
そのトピックに登録されている DestinationTopic インスタンスを返します。
getDestinationTopicProperties() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfiguration
getDltFor(String, String, Exception) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver
getDltFor(String, String, Exception) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicContainer
スローされた例外を考慮して、指定されたトピックの DLT として登録された DestinationTopic インスタンスを返します。見つからない場合は null を返します。
getDltHandlerMethod() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfiguration
getDltSuffix() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopicPropertiesFactory.DestinationTopicSuffixes
getDueTimestamp() - Method in exception org.springframework.kafka.listener.KafkaBackoffException
getDueTimestamp() - クラス org.springframework.kafka.listener のメソッド。KafkaConsumerBackoffManager.Context
getEndOffsets(Consumer<?, ?>, String, Integer...) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
リクエストされたトピック / パーティションの終了オフセットを返します
getEndpointDescription() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
このエンドポイントの説明を返します。
getEndpointDescription() - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint
getEndpointHandlerMethod(MethodKafkaListenerEndpoint<?, ?>, RetryTopicConfiguration, DestinationTopic.Properties) - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicConfigurer
getEndpointId(KafkaListenerEndpoint) - インターフェース org.springframework.kafka.retrytopic のメソッド。RetryTopicNamesProviderFactory.RetryTopicNamesProvider
エンドポイントの現在の ID を上書きするエンドポイント ID を返します。
getEndpointId(KafkaListenerEndpoint) - クラス org.springframework.kafka.retrytopic のメソッド。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getEndpointRegistrar() - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor
getEndpointRegistry() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar
このレジストラの KafkaListenerEndpointRegistry インスタンスを返します。null の場合があります。
getEntries() - クラス org.springframework.kafka.support のメソッド。ExceptionMatcher
getEosMode() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
一度だけのセマンティクスモードを取得します。
getException() - クラス org.springframework.kafka.support.serializer のメソッド。FailedDeserializationInfo
getExceptionCauseFqcn() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
例外原因のヘッダー名。
getExceptionFqcn() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
値例外クラスのヘッダー名。
getExceptionFromHeader(ConsumerRecord<?, ?>, String, LogAccessor) - Static method in class org.springframework.kafka.support.serializer.SerializationUtils
存在する場合は、指定されたヘッダー名から DeserializationException を抽出します。
getExceptionInfo() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames
例外ヘッダーのヘッダー名。
getExceptionMatcher() - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier
ExceptionMatcher を返します。
getExceptionMessage() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
例外メッセージのヘッダー名。
getExceptionStacktrace() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
例外スタックトレースのヘッダー名。
getFailedProducerRecord() - Method in exception org.springframework.kafka.core.KafkaProducerException
失敗したプロデューサーレコードを返します。
getFailureTracker() - クラス org.springframework.kafka.listener のメソッド。FailedRecordProcessor
失敗したレコードトラッカーを返します。
getFallbackBatchHandler() - クラス org.springframework.kafka.listener のメソッド。FailedBatchProcessor
フォールバックバッチエラーハンドラーを返します。
getGroup() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getGroup() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントのグループを返すか、グループにない場合は null を返します。
getGroup(KafkaListenerEndpoint) - インターフェース org.springframework.kafka.retrytopic のメソッド。RetryTopicNamesProviderFactory.RetryTopicNamesProvider
エンドポイントのグループをオーバーライドするグループを返します。
getGroup(KafkaListenerEndpoint) - クラス org.springframework.kafka.retrytopic のメソッド。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getGroupId() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getGroupId() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの groupId を返します。存在する場合は、コンシューマーファクトリの group.id プロパティをオーバーライドします。
getGroupId() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getGroupId() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
getGroupId() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
コンテナーのグループ ID を返します。
getGroupId() - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware.ConsumerSeekCallback
利用可能な場合、このコンシューマーシークコールバックに関連付けられているグループ ID を取得します。
getGroupId() - Method in exception org.springframework.kafka.listener.ListenerExecutionFailedException
この例外をスローしたコンテナーのコンシューマー group.id プロパティを返します。
getGroupId() - インターフェース org.springframework.kafka.listener のメソッド。ListenerMetadata
グループ ID を返します。
getGroupId() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
コンテナーに明示的に設定されているか、コンシューマーファクトリのコンシューマープロパティを介して設定されているかにかかわらず、このコンテナーの group.id プロパティを返します。
getGroupId() - Static method in interface org.springframework.kafka.support.converter.MessageConverter
スレッドにバインドされたグループ ID を取得します。
getGroupId() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
コンシューマーグループ ID を返します。
getGroupId(KafkaListenerEndpoint) - インターフェース org.springframework.kafka.retrytopic のメソッド。RetryTopicNamesProviderFactory.RetryTopicNamesProvider
エンドポイントの groupId をオーバーライドする groupId を返します。
getGroupId(KafkaListenerEndpoint) - クラス org.springframework.kafka.retrytopic のメソッド。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getHandlerForPayload(Class<?>) - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler
指定された型の InvocableHandlerMethod を判別します。
getHeader(String, Class<T>) - クラス org.springframework.kafka.support のメソッド。KafkaMessageHeaderAccessor
特定の型のヘッダー値を取得します。
getHeaders() - Method in exception org.springframework.kafka.support.serializer.DeserializationException
ヘッダーを取得します。
getHeaders() - クラス org.springframework.kafka.support.serializer のメソッド。FailedDeserializationInfo
getHeadersFunction() - クラス org.springframework.kafka.listener のメソッド。DeadLetterRecordManager
ヘッダー関数を返します。
getHeaderValue() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper.NonTrustedHeaderType
使用すべきではありません。
getHeaderValue() - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper.NonTrustedHeaderType
getHighCardinalityKeyValues(KafkaRecordReceiverContext) - クラス org.springframework.kafka.support.micrometer のメソッド。KafkaListenerObservation.DefaultKafkaListenerObservationConvention
getHost() - クラス org.springframework.kafka.test.core のメソッド。BrokerAddress
getId() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getId() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの ID を返します。
getIdClassMapping() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
使用すべきではありません。
getIdClassMapping() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper
getIdleBeforeDataMultiplier() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
少なくとも 1 つのレコードが受信されるまで、ContainerProperties.setIdleEventInterval(Long) にこの値を掛けます。
getIdleBetweenPolls() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getIdleEventInterval() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
アイドルイベント間隔を返します。
getIdlePartitionEventInterval() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
アイドルパーティションイベント間隔を返します。
getIdleTime() - クラス org.springframework.kafka.event のメソッド。ListenerContainerIdleEvent
コンテナーがアイドル状態になっている時間。
getIdleTime() - クラス org.springframework.kafka.event のメソッド。ListenerContainerNoLongerIdleEvent
コンテナーがアイドル状態だった時間。
getIdleTime() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionIdleEvent
パーティションがアイドル状態になっている時間。
getIdleTime() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionNoLongerIdleEvent
パーティションがアイドル状態だった時間。
getIndex() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
失敗したレコードのバッチでインデックスを返します。
getInvocationResultFor(Object, Object) - クラス org.springframework.kafka.listener.adapter のメソッド。HandlerAdapter
getInvocationResultFor(Object, Object) - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler
結果とペイロードを指定して、メソッド呼び出しの結果を返します。
getJsonMapper() - クラス org.springframework.kafka.support.converter のメソッド。JacksonJsonMessageConverter
オブジェクトマッパーを返します。
getJsonMapper() - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper
オブジェクトマッパーを返します。
getKafkaAdmin() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
存在する場合、観測用のクラスター ID を見つけるために使用される KafkaAdmin を返します。
getKafkaAdmin() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
存在する場合、観測用のクラスター ID を見つけるために使用される KafkaAdmin を返します。
getKafkaAwareTransactionManager() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getKafkaConsumerProperties() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
コンシューマーファクトリによって提供されるコンシューマープロパティとマージされるコンシューマープロパティを取得します。ここのプロパティは、コンシューマーファクトリの同じ名前のプロパティよりも優先されます。
getKafkaOperations() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopic
getKafkaStreams() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
この StreamsBuilderFactoryBean KafkaStreams インスタンスによって管理されます。
getKafkaStreamsApplicationHostInfo(String, K, Serializer<K>) - クラス org.springframework.kafka.streams のメソッド。KafkaStreamsInteractiveQueryService
提供されたストアとキーがホストされている HostInfo を取得します。
getKey() - クラス org.springframework.kafka.streams のメソッド。HeaderEnricherProcessor.Container
getKeyClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
使用すべきではありません。
getKeyClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper
getKeyDeserializer() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory
構成されたキーデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getKeyDeserializer() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory
getKeyDeserializer() - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory
getKeyDeserializer() - インターフェース org.springframework.kafka.core のメソッド。ShareConsumerFactory
構成されたキーデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getKeyExceptionFqcn() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
キー例外クラスのヘッダー名。
getKeyExceptionMessage() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
キー例外メッセージのヘッダー名。
getKeyExceptionStacktrace() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.ExceptionInfo
キー例外スタックトレースのヘッダー名。
getKeySerializer() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getKeySerializer() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
構成されたキーシリアライザーを返します(プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getKeySerializerSupplier() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getKeySerializerSupplier() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
キーシリアライザのサプライヤーを返します。
getListenerContainer(String) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
指定された ID を持つ MessageListenerContainer またはそのようなコンテナーが存在しない場合は null を返します。
getListenerContainer(String) - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
指定された ID を持つ MessageListenerContainer またはそのようなコンテナーが存在しない場合は null を返します。
getListenerContainerIds() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
マネージド MessageListenerContainer インスタンスの ID を返します。
getListenerContainerIds() - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
マネージド MessageListenerContainer インスタンスの ID を返します。
getListenerContainerRegistry() - クラス org.springframework.kafka.listener のメソッド。AbstractKafkaBackOffManagerFactory
getListenerContainers() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
マネージド MessageListenerContainer インスタンスを返します。
getListenerContainers() - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
マネージド MessageListenerContainer インスタンスを返します。
getListenerContainersMatching(BiPredicate<String, MessageListenerContainer>) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
指定された双述語を満たすすべての MessageListenerContainer インスタンスを返します。
getListenerContainersMatching(BiPredicate<String, MessageListenerContainer>) - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
指定された双述語を満たすすべての MessageListenerContainer インスタンスを返します。
getListenerContainersMatching(Predicate<String>) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
述語に一致する ID を持つすべての MessageListenerContainer インスタンスを返します。そのようなコンテナーが存在しない場合は空の CollectionSE を返します。
getListenerContainersMatching(Predicate<String>) - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
述語に一致する ID を持つすべての MessageListenerContainer インスタンスを返します。そのようなコンテナーが存在しない場合は空の CollectionSE を返します。
getListenerId() - クラス org.springframework.kafka.event のメソッド。ListenerContainerIdleEvent
リスナーの ID ( @KafkaListener の場合) またはコンテナーの Bean 名。
getListenerId() - クラス org.springframework.kafka.event のメソッド。ListenerContainerNoLongerIdleEvent
リスナーの ID ( @KafkaListener の場合) またはコンテナーの Bean 名。
getListenerId() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionIdleEvent
リスナーの ID ( @KafkaListener の場合) またはコンテナーの Bean 名。
getListenerId() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionNoLongerIdleEvent
リスナーの ID ( @KafkaListener の場合) またはコンテナーの Bean 名。
getListenerId() - クラス org.springframework.kafka.event のメソッド。NonResponsiveConsumerEvent
リスナーの ID ( @KafkaListener の場合) またはコンテナーの Bean 名。
getListenerId() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getListenerId() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
getListenerId() - Method in exception org.springframework.kafka.listener.KafkaBackoffException
getListenerId() - クラス org.springframework.kafka.listener のメソッド。KafkaConsumerBackoffManager.Context
getListenerId() - インターフェース org.springframework.kafka.listener のメソッド。ListenerMetadata
リスナー ID を返します。
getListenerId() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
@KafkaListener の 'id' 属性 または spring-managed コンテナーの Bean 名。
getListenerId() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
リスナー ID を返します。
getListenerIds() - クラス org.springframework.kafka.listener のメソッド。ContainerGroup
このグループのコンテナーのリスナー ID を返します。
getListenerInfo() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getListenerInfo() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
レコードヘッダーに挿入するリスナー情報を取得します。
getListenerInfo() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getListenerInfo() - インターフェース org.springframework.kafka.listener のメソッド。ListenerMetadata
リスナー情報を返します。
getListenerInfo() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
すべてのレコードの KafkaHeaders.LISTENER_INFO ヘッダーに追加される任意の静的情報を取得します。
getListeners() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
リスナーの現在のリストを取得します。
getListeners() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory
リスナーの現在のリストを取得します。
getListeners() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory
リスナーの現在のリストを取得します。
getListeners() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
リスナーの現在のリストを取得します。
getListeners() - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory
リスナーの現在のリストを取得します。
getListeners() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
リスナーの現在のリストを取得します。
getListeners() - インターフェース org.springframework.kafka.core のメソッド。ShareConsumerFactory
リスナーの現在のリストを取得します。
getListenerTaskExecutor() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
コンシューマータスクエグゼキュータを返します。
getLogLevel() - クラス org.springframework.kafka.listener のメソッド。KafkaExceptionLogLevelAware
このハンドラーによってスローされた例外がログに記録されるレベルを設定します。
getLowCardinalityKeyValues(KafkaRecordReceiverContext) - クラス org.springframework.kafka.support.micrometer のメソッド。KafkaListenerObservation.DefaultKafkaListenerObservationConvention
getLowCardinalityKeyValues(KafkaRecordSenderContext) - クラス org.springframework.kafka.support.micrometer のメソッド。KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
getMainListenerId() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getMainListenerId() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このコンテナーが再試行トピック用である場合は、メインリスナー ID を返します。
getMainListenerId() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getMainListenerId() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer
メイン @KafkaListener コンテナーの 'id' 属性 (このコンテナーが再試行トピック用の場合)。それ以外の場合は null。
getMaxRetries() - クラス org.springframework.kafka.support のメソッド。ExponentialBackOffWithMaxRetries
最大再試行回数を取得します。
getMessage() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
getMessageConverter() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
メッセージコンバーターを返します。
getMessageConverter() - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter
Message を変換できるようにして、このリスナーの MessagingMessageConverter を返します。
getMessageHandlerMethodFactory() - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor
設定されたハンドラーファクトリを返します。
getMessageHandlerMethodFactory() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar
使用するカスタム MessageHandlerMethodFactory があれば、それを返します。
getMessageHandlerMethodFactory() - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint
MessageHandlerMethodFactory を返します。
getMessageListener() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getMessagingConverter() - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter
getMethod() - クラス org.springframework.kafka.config のメソッド。MethodKafkaListenerEndpoint
getMethod() - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMethod
メソッドを返します。
getMethodAsString(Object) - クラス org.springframework.kafka.listener.adapter のメソッド。HandlerAdapter
getMethodName() - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMethod
メソッド名を返します。
getMethodNameFor(Object) - クラス org.springframework.kafka.listener.adapter のメソッド。DelegatingInvocableHandler
このペイロードに対して呼び出されるメソッドの文字列表現を返します。
getMethods() - クラス org.springframework.kafka.config のメソッド。MultiMethodKafkaListenerEndpoint
メソッドリストを取得します。
getMethods() - クラス org.springframework.kafka.support のメソッド。EndpointHandlerMultiMethod
メソッドリストを返します。
getMicrometerTags() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
静的 Micrometer タグを返します。
getMicrometerTagsProvider() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
Micrometer タグプロバイダーを返します。
getMicrometerTagsProvider() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
Micrometer タグプロバイダーを返します。
getMonitorInterval() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getMsg() - Method in exception org.springframework.kafka.support.converter.ConversionException
可能であれば、Message を返します。
getName() - クラス org.springframework.kafka.listener のメソッド。ContainerGroup
グループ名を返します。
getName() - Method in interface org.springframework.kafka.support.micrometer.KafkaListenerObservationConvention
getName() - クラス org.springframework.kafka.support.micrometer のメソッド。KafkaTemplateObservation.DefaultKafkaTemplateObservationConvention
getName() - Method in interface org.springframework.kafka.support.micrometer.KafkaTemplateObservationConvention
getNextDestination() - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver.DestinationTopicHolder
getNextDestinationTopicFor(String, String) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver
getNextDestinationTopicFor(String, String) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicContainer
指定されたトピックの チェーンに次の宛先トピックとして登録されている DestinationTopic インスタンスを返します。
getNonBlockingRetryDeliveryAttempt() - クラス org.springframework.kafka.support のメソッド。KafkaMessageHeaderAccessor
ノンブロッキング再試行を使用する場合は、配信試行ヘッダー値を int として取得します。
getNoPollThreshold() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getObjectMapper() - クラス org.springframework.kafka.support.converter のメソッド。JsonMessageConverter
使用すべきではありません。
オブジェクトマッパーを返します。
getObjectMapper() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper
使用すべきではありません。
オブジェクトマッパーを返します。
getObjectType() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
getObservationConvention() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getObservationRegistry() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
テンプレートで使用される ObservationRegistry を返します。
getObservationRegistry() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getOffset() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
オフセットを返します。
getOffset() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset
getOffsetAndMetadataProvider() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
オフセットおよびメタデータプロバイダーを返します。
getOffsetComputeFunction() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset
getOffsetHeader() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Original
オフセットのヘッダー名。
getOneRecord(String, String, String, int, boolean, boolean, Duration) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
トピック / パーティションからグループの単一のレコードを取得します。
getOperationTimeout() - クラス org.springframework.kafka.core のメソッド。KafkaAdmin
操作のタイムアウトを秒単位で返します。
getOrder() - クラス org.springframework.kafka.annotation のメソッド。KafkaListenerAnnotationBeanPostProcessor
getOrder() - インターフェース org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBeanConfigurer
getOriginal() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames
元のレコードヘッダーのヘッダー名。
getParser() - クラス org.springframework.kafka.support.serializer のメソッド。ParseStringDeserializer
構成されたパーサー関数を取得します。
getPartition() - クラス org.springframework.kafka.event のメソッド。ConsumerPartitionPausedEvent
一時停止したパーティションを返します。
getPartition() - クラス org.springframework.kafka.event のメソッド。ConsumerPartitionResumedEvent
getPartition() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
パーティションを戻します。
getPartition() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset
getPartitionHeader() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Original
パーティションのヘッダー名。
getPartitions() - クラス org.springframework.kafka.event のメソッド。ConsumerPausedEvent
一時停止したパーティションを返します。
getPartitions() - クラス org.springframework.kafka.event のメソッド。ConsumerResumedEvent
getPartitions() - クラス org.springframework.kafka.event のメソッド。ConsumerStoppingEvent
getPartitionsPerTopic() - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker
トピックごとに構成されたパーティション数を取得します。
getPartitionsPerTopic() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker
getPhase() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
getPhase() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
getPhase() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getPhase() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
getPhase() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
getPhase() - クラス org.springframework.kafka.listener のメソッド。ContainerGroupSequencer
getPhase() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate
getPhysicalCloseTimeout() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
物理的なクローズタイムアウトを取得します。
getPhysicalCloseTimeout() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
物理的なクローズタイムアウトを取得します。
getPollTimeout() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
getPollTimeoutWhilePaused() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
一時停止中に使用するポーリングタイムアウト。通常は pollTimeout よりも小さい数値です。
getPort() - クラス org.springframework.kafka.test.core のメソッド。BrokerAddress
getPosition() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset
getPostProcessors() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory
ポストプロセッサーの現在のリストを取得します。
getPostProcessors() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory
getPostProcessors() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getPostProcessors() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
ポストプロセッサーの現在のリストを取得します。
getProducer() - クラス org.springframework.kafka.core のメソッド。KafkaResourceHolder
getProducerConfigs() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
プロデューサーの構成を返します。
getProducerFactory() - インターフェース org.springframework.kafka.core のメソッド。KafkaOperations
このテンプレートで使用されるプロデューサーファクトリを返します。
getProducerFactory() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
このテンプレートで使用されるプロデューサーファクトリを返します。
getProducerFactory() - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate
getProducerFactory() - クラス org.springframework.kafka.transaction のメソッド。ChainedKafkaTransactionManager
使用すべきではありません。
getProducerFactory() - インターフェース org.springframework.kafka.transaction のメソッド。KafkaAwareTransactionManager
生産ファクトリを取得します。
getProducerFactory() - クラス org.springframework.kafka.transaction のメソッド。KafkaTransactionManager
生産ファクトリを取得します。
getProducerFactory(String) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
トピックに基づいて、このテンプレートで使用されるプロデューサーファクトリを返します。
getProducerFactory(String) - クラス org.springframework.kafka.core のメソッド。RoutingKafkaTemplate
getProducerRecord() - クラス org.springframework.kafka.support のメソッド。SendResult
getPropertyValue(Object, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
ネストされた DirectFieldAccessor を使用して、ドット表記を使用してプロパティを取得し、フィールドをトラバースします。たとえば
getPropertyValue(Object, String, Class<T>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
getRawHeaders() - クラス org.springframework.kafka.support.converter のメソッド。KafkaMessageHeaders
getReason() - クラス org.springframework.kafka.event のメソッド。ConcurrentContainerStoppedEvent
コンテナーが停止された理由を返します。
getReason() - クラス org.springframework.kafka.event のメソッド。ConsumerRetryAuthEvent
認証失敗の理由を返します。
getReason() - クラス org.springframework.kafka.event のメソッド。ConsumerStoppedEvent
コンシューマーが停止した理由を返します。
getRecord() - Method in exception org.springframework.kafka.listener.BatchListenerFailedException
失敗したレコードを返します。
getRecord() - クラス org.springframework.kafka.streams のメソッド。HeaderEnricherProcessor.Container
getRecord() - Method in exception org.springframework.kafka.support.converter.ConversionException
可能な場合は、コンシューマーレコードを返します。
getRecord() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
コンシューマーレコードを返します。
getRecord() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordSenderContext
プロデューサーのレコードを返します。
getRecordFilterStrategy() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getRecordFilterStrategy() - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractFilteringMessageListener
getRecordInterceptor() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerContainerFactory
構成されている場合は、変更のために RecordInterceptor を取得します。
getRecordInterceptor() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
構成されている場合は、変更のために RecordInterceptor を取得します。
getRecordMessageConverter() - インターフェース org.springframework.kafka.support.converter のメソッド。BatchMessageConverter
このバッチコンバーターが使用するレコードコンバーター (構成されている場合) または null を返します。
getRecordMessageConverter() - クラス org.springframework.kafka.support.converter のメソッド。BatchMessagingMessageConverter
getRecordMetadata() - クラス org.springframework.kafka.support のメソッド。SendResult
getRecords() - Method in exception org.springframework.kafka.support.converter.ConversionException
可能な場合は、コンシューマーレコードを返します。
getRecords(Consumer<K, V>) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
記録のためにコンシューマーをポーリングします。
getRecords(Consumer<K, V>, Duration) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
記録のためにコンシューマーをポーリングします。
getRecords(Consumer<K, V>, Duration, int) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
記録のためにコンシューマーをポーリングします。
getReplyHeadersConfigurer() - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter
応答コンフィギュレータを返します。
getReplyTemplate() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getResolver() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
getRetryListeners() - クラス org.springframework.kafka.listener のメソッド。FailedRecordProcessor
getRetrySuffix() - クラス org.springframework.kafka.retrytopic のメソッド。DestinationTopicPropertiesFactory.DestinationTopicSuffixes
getScheduler() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
存在する場合は、タスクスケジューラを返します。
getScheduler() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicSchedulerWrapper
getSeekCallbacksFor(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware
指定されたトピック / パーティションのコールバックを返します。
getSendFuture() - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyFuture
送信先を返します。
getSendFuture() - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyMessageFuture
送信先を返します。
getShareAckMode() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
共有コンシューマーコンテナーの確認応答モードを返します。
getShareAcknowledgmentTimeout() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
ContainerProperties.ShareAckMode.MANUAL モードでの共有確認応答のタイムアウトを取得します。
getShareConsumerRecordRecoverer() - クラス org.springframework.kafka.listener のメソッド。AbstractShareKafkaMessageListenerContainer
設定された ShareConsumerRecordRecoverer を返します。
getShutdownTimeout() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
getSingleRecord(Consumer<K, V>, String) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
指定されたトピックの単一のレコードを期待して、コンシューマーをポーリングします。
getSingleRecord(Consumer<K, V>, String, Duration) - Static method in class org.springframework.kafka.test.utils.KafkaTestUtils
指定されたトピックの単一のレコードを期待して、コンシューマーをポーリングします。
getSource() - Method in class org.springframework.kafka.support.micrometer.KafkaRecordReceiverContext
ソーストピックを返します。
getSource(Class<T>) - クラス org.springframework.kafka.event のメソッド。KafkaEvent
イベントを公開したコンテナー(ソース)を取得します。
getSourceDestination() - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver.DestinationTopicHolder
getStreamsConfiguration() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
getStreamsUncaughtExceptionHandler() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
このファクトリ Bean に設定されている現在の StreamsUncaughtExceptionHandler を取得します。
getSubBatchPerPartition() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
パーティションごとにバッチを分割するかどうかを返します。設定されていない場合は null。
getSyncCommitTimeout() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
同期コミットタイムアウトを返します。
getTheProducer(String) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
getThreadNameSupplier() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer
コンシューマースレッド名を変更するために使用される関数を返します。
getTimeoutBuffer() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer
Kafka プロデューサーの前にタイムアウトにならないようにするために、プロデューサー構成 delivery.timeout.ms プロパティに追加するミリ秒数。
getTimeSinceLastPoll() - クラス org.springframework.kafka.event のメソッド。NonResponsiveConsumerEvent
前回の投票からの経過時間。
getTimestamp() - Method in exception org.springframework.kafka.listener.TimestampedException
getTimestampHeader() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Original
タイムスタンプのヘッダー名。
getTimestampTypeHeader() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Original
タイムスタンプ型のヘッダー名。
getTopic() - クラス org.springframework.kafka.support.serializer のメソッド。FailedDeserializationInfo
getTopic() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset
getTopicHeader() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Original
トピックのヘッダー名。
getTopicName(String) - インターフェース org.springframework.kafka.retrytopic のメソッド。RetryTopicNamesProviderFactory.RetryTopicNamesProvider
ベーストピック名を上書きする熱帯の名前を返します。
getTopicName(String) - クラス org.springframework.kafka.retrytopic のメソッド。SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
getTopicPartition() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionIdleEvent
アイドル状態の TopicPartition。
getTopicPartition() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionNoLongerIdleEvent
アイドル状態の TopicPartition。
getTopicPartition() - Method in exception org.springframework.kafka.listener.KafkaBackoffException
getTopicPartition() - クラス org.springframework.kafka.listener のメソッド。KafkaConsumerBackoffManager.Context
getTopicPartition() - クラス org.springframework.kafka.support のメソッド。TopicPartitionOffset
getTopicPartitions() - クラス org.springframework.kafka.event のメソッド。ListenerContainerIdleEvent
コンテナーがリッスンしている TopicPartitions。
getTopicPartitions() - クラス org.springframework.kafka.event のメソッド。ListenerContainerNoLongerIdleEvent
コンテナーがリッスンしている TopicPartitions。
getTopicPartitions() - クラス org.springframework.kafka.event のメソッド。NonResponsiveConsumerEvent
コンテナーがリッスンしている TopicPartitions。
getTopicPartitions() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
構成済みの TopicPartitionOffset を返します。
getTopicPartitionsToAssign() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
このエンドポイントの topicPartitions を返します。
getTopicPartitionsToAssign() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの topicPartitions を返します。
getTopicPattern() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
このエンドポイントの topicPattern を返します。
getTopicPattern() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントの topicPattern を返します。
getTopicPattern() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
構成されたトピックパターンを返します。
getTopics() - クラス org.springframework.kafka.config のメソッド。AbstractKafkaListenerEndpoint
このエンドポイントのトピックを返します。
getTopics() - インターフェース org.springframework.kafka.config のメソッド。KafkaListenerEndpoint
このエンドポイントのトピックを返します。
getTopics() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties
構成されたトピックを返します。
getTopics() - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker
トピックを取得します。
getTopics() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker
getTopicsAndCallbacks() - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware
現在割り当てられているすべてのパーティションのコールバックのマップ。
getTopology() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean
この StreamsBuilderFactoryBean の関連する Topology へのアクセスを提供します。
getToStringClasses() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper
使用すべきではありません。
サブクラスによる toString() クラスへの直接アクセスを提供します。
getToStringClasses() - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper
サブクラスによる toString() クラスへの直接アクセスを提供します。
getTransactionalResourceHolder(ProducerFactory<K, V>) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils
現在のトランザクションと同期している Producer を取得します (存在する場合)。
getTransactionalResourceHolder(ProducerFactory<K, V>, String, Duration) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils
現在のトランザクションと同期している Producer を取得します (存在する場合)。
getTransactionalResourceHolder(ProducerFactory<K, V>, Duration) - Static method in class org.springframework.kafka.core.ProducerFactoryUtils
現在のトランザクションと同期している Producer を取得します (存在する場合)。
getTransactionDefinition() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
トランザクション定義を取得します。
getTransactionIdPrefix() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getTransactionIdPrefix() - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
getTransactionIdPrefix() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
トランザクション ID プレフィックスを返します。
getTransactionManager() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
getTrustedPackages() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper
使用すべきではありません。
サブクラスに設定された信頼できるパッケージへの直接アクセスを提供します。
getTrustedPackages() - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper
サブクラスに設定された信頼できるパッケージへの直接アクセスを提供します。
getTxIdPrefix() - Method in exception org.springframework.kafka.core.NoProducerAvailableException
プロデューサーの作成に使用され、失敗したトランザクション ID プレフィックスを返します。
getTxProducerConfigs(String) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
トランザクションプロデューサーの構成を返します。
getType() - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter
変換のために推論された型を返します。null の場合は fallbackType を返します。
getTypeMapper() - クラス org.springframework.kafka.support.converter のメソッド。JacksonJsonMessageConverter
getTypeMapper() - クラス org.springframework.kafka.support.converter のメソッド。JsonMessageConverter
使用すべきではありません。
getTypeMapper() - クラス org.springframework.kafka.support.converter のメソッド。MappingJacksonJsonParameterizedConverter
型マッパーを返します。
getTypeMapper() - クラス org.springframework.kafka.support.converter のメソッド。MappingJacksonParameterizedConverter
使用すべきではありません。
型マッパーを返します。
getTypeMapper() - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonDeserializer
getTypeMapper() - クラス org.springframework.kafka.support.serializer のメソッド。JacksonJsonSerializer
getTypeMapper() - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer
使用すべきではありません。
getTypeMapper() - クラス org.springframework.kafka.support.serializer のメソッド。JsonSerializer
使用すべきではありません。
getTypePrecedence() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper
使用すべきではありません。
優先順位を返します。
getTypePrecedence() - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJacksonJavaTypeMapper
優先順位を返します。
getTypePrecedence() - インターフェース org.springframework.kafka.support.mapping のメソッド。Jackson2JavaTypeMapper
使用すべきではありません。
getTypePrecedence() - インターフェース org.springframework.kafka.support.mapping のメソッド。JacksonJavaTypeMapper
getUnregisteredListenerContainer(String) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
getUnregisteredListenerContainer(String) - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry
指定された ID を持つ MessageListenerContainer またはそのようなコンテナーが存在しない場合は null を返します。
getUntrustedType() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper.NonTrustedHeaderType
使用すべきではありません。
getUntrustedType() - クラス org.springframework.kafka.support のメソッド。JsonKafkaHeaderMapper.NonTrustedHeaderType
getValidator() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar
提供されている場合、バリデーターを取得します。
getValue() - クラス org.springframework.kafka.streams のメソッド。HeaderEnricherProcessor.Container
getValueDeserializer() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory
構成された値のデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getValueDeserializer() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory
getValueDeserializer() - クラス org.springframework.kafka.core のメソッド。DefaultShareConsumerFactory
getValueDeserializer() - インターフェース org.springframework.kafka.core のメソッド。ShareConsumerFactory
構成された値のデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getValueSerializer() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getValueSerializer() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
構成された値シリアライザーを返します(プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getValueSerializerSupplier() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getValueSerializerSupplier() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory
値シリアライザーのサプライヤーを返します。
GlobalEmbeddedKafkaTestExecutionListener - org.springframework.kafka.test.junit のクラス
テスト計画の最初に EmbeddedKafkaBroker を開始し、最後に停止する TestExecutionListener
GlobalEmbeddedKafkaTestExecutionListener() - クラス org.springframework.kafka.test.junit. GlobalEmbeddedKafkaTestExecutionListener のコンストラクター
GROUP - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd
失敗したレコードを受け取ったコンシューマーグループ。
GROUP_ID - Static variable in class org.springframework.kafka.support.KafkaHeaders
受信メッセージの場合、コンテナーの group.id コンシューマープロパティ。
groupId() - Element in annotation interface org.springframework.kafka.annotation.KafkaListener
コンシューマーファクトリの group.id プロパティを、このリスナーに対してのみこの値でオーバーライドします。
A B C D E F G H I J K L M N O P R S T U V W
すべてのクラスとインターフェース | すべてのパッケージ | 定数フィールド値 | 連載形式