G- インデックス (Spring for Apache Kafka API)

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

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.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
getApplicationEventPublisher() - クラス org.springframework.kafka.listener のメソッド。AbstractMessageListenerContainer: イベントの発行元を取得します。
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.listener のメソッド。AbstractMessageListenerContainer
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() - 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
getBrokerAddress(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getBrokerAddresses() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getBrokersAsString() - インターフェース org.springframework.kafka.test のメソッド。EmbeddedKafkaBroker: ブートストラップサーバーのアドレスを文字列として取得します。
getBrokersAsString() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaKraftBroker
getBrokersAsString() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
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
getClassifier() - クラス org.springframework.kafka.listener のメソッド。ExceptionClassifier: 例外分類子を返します。
getClassLoader() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
getClientId() - クラス org.springframework.kafka.listener のメソッド。ConsumerProperties: クライアント 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
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 のメソッド。KafkaAdmin
getConfigurationProperties() - インターフェース org.springframework.kafka.core のメソッド。KafkaAdminOperations: この管理者の構成の変更不可能なコピーを取得します。
getConfigurationProperties() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory: このファクトリの構成マップへの変更不可能な参照を返します。
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: コンシューマーを取得します。
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.listener のメソッド。AbstractMessageListenerContainer
getContainerProperties() - インターフェース org.springframework.kafka.listener のメソッド。MessageListenerContainer: このコンテナーのコンテナープロパティを返します。
getContainers() - クラス org.springframework.kafka.listener のメソッド。ConcurrentMessageListenerContainer: このコンテナーによって作成された KafkaMessageListenerContainer のリストを返します。
getContentClassIdFieldName() - クラス org.springframework.kafka.support.mapping のメソッド。AbstractJavaTypeMapper
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
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) - インターフェース org.springframework.kafka.retrytopic のメソッド。DestinationTopicContainer: 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
DestinationTopicContainer.getDltFor(String, String, Exception) に置き換えられました
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
getEmbeddedKafka() - クラス org.springframework.kafka.test.rule のメソッド。EmbeddedKafkaRule: 基になる委譲者 EmbeddedKafkaBroker インスタンスを返します。
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: KafkaListenerEndpointRegistrar を返します。
getEndpointRegistry() - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistrar: このレジストラの KafkaListenerEndpointRegistry インスタンスを返します。null の場合があります。
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: 例外ヘッダーのヘッダー名。
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 のメソッド。ConsumerProperties: コンテナーのグループ 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: 特定の型のヘッダー値を取得します。
getHeaderNames() - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer: 非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。
3.0.9 以降 - 代わりにサプライヤーを提供してください。
getHeaders() - Method in exception org.springframework.kafka.support.serializer.DeserializationException: ヘッダーを取得します。
getHeaders() - クラス org.springframework.kafka.support.serializer のメソッド。FailedDeserializationInfo
getHeaderValue() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper.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
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 のメソッド。DelegatingInvocableHandler: 結果とペイロードを指定して、メソッド呼び出しの結果を返します。
getInvocationResultFor(Object, Object) - クラス org.springframework.kafka.listener.adapter のメソッド。HandlerAdapter
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
getKafkaServer(int) - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getKafkaServers() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
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
getKeyDeserializer() - インターフェース org.springframework.kafka.core のメソッド。ConsumerFactory: 構成されたキーデシリアライザーを返します (プロパティでクラス名の代わりにオブジェクトとして提供されている場合)。
getKeyDeserializer() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaConsumerFactory
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() - 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 のメソッド。ProducerFactory: リスナーの現在のリストを取得します。
getListenerTaskExecutor() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties: コンシューマータスクエグゼキュータを返します。
getLogDir() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaZKBroker.EmbeddedZookeeper
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。
getMaxAttempts(int) - クラス org.springframework.kafka.retrytopic のメソッド。BackOffValuesGenerator
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
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 のメソッド。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 のメソッド。ConsumerPartitionPausedEvent: 一時停止したパーティションを返します。
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
getPartitionsPerTopic() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
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 のメソッド。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
getPort() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaZKBroker.EmbeddedZookeeper
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: KafkaTestUtils.getPropertyValue(Object, String) の型付きバージョン。
getRawHeaders() - クラス org.springframework.kafka.support.converter のメソッド。KafkaMessageHeaders
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.listener のメソッド。AbstractMessageListenerContainer
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: 記録のためにコンシューマーをポーリングします。
getRecoveryCallback() - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractRetryingMessageListenerAdapter
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
getRetryTemplate() - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractRetryingMessageListenerAdapter
getScheduler() - クラス org.springframework.kafka.listener のメソッド。ContainerProperties: 存在する場合は、タスクスケジューラを返します。
getScheduler() - クラス org.springframework.kafka.retrytopic のメソッド。RetryTopicSchedulerWrapper
getSeekCallbackFor(TopicPartition) - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware: 指定されたトピック / パーティションのコールバックを返します。
getSeekCallbacks() - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware: 現在割り当てられているすべてのパーティションのコールバックのマップ。
getSendFuture() - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyFuture: 送信先を返します。
getSendFuture() - クラス org.springframework.kafka.requestreply のメソッド。RequestReplyMessageFuture: 送信先を返します。
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: 指定されたトピックの単一のレコードを期待して、コンシューマーをポーリングします。
getSnapshotDir() - クラス org.springframework.kafka.test のメソッド。EmbeddedKafkaZKBroker.EmbeddedZookeeper
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
getTopics() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getTopology() - クラス org.springframework.kafka.config のメソッド。StreamsBuilderFactoryBean: この StreamsBuilderFactoryBean の関連する Topology へのアクセスを提供します。
getToStringClasses() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper: サブクラスによる 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: サブクラスに設定された信頼できるパッケージへの直接アクセスを提供します。
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 のメソッド。JsonMessageConverter
getTypeMapper() - クラス org.springframework.kafka.support.converter のメソッド。MappingJacksonParameterizedConverter: 型マッパーを返します。
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 のメソッド。Jackson2JavaTypeMapper
getUnregisteredListenerContainer(String) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
getUnregisteredListenerContainer(String) - インターフェース org.springframework.kafka.listener のメソッド。ListenerContainerRegistry: 指定された ID を持つ MessageListenerContainer またはそのようなコンテナーが存在しない場合は null を返します。
getUntrustedType() - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper.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
getValueSerializer() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getValueSerializer() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory: 構成された値シリアライザーを返します（プロパティでクラス名の代わりにオブジェクトとして提供されている場合）。
getValueSerializerSupplier() - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
getValueSerializerSupplier() - インターフェース org.springframework.kafka.core のメソッド。ProducerFactory: 値シリアライザーのサプライヤーを返します。
getZkPort() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker: 組み込み Zookeeper が実行されている、または実行されるポートを取得します。
getZookeeper() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
getZooKeeperClient() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker: ZooKeeperClient を返します。
getZookeeperConnectionString() - Method in class org.springframework.kafka.test.EmbeddedKafkaZKBroker
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 Z
すべてのクラスとインターフェース | すべてのパッケージ | 定数フィールド値 | 直列化された形式