インデックス

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

O

objectMapper - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer
使用すべきではありません。
objectMapper - Variable in class org.springframework.kafka.support.serializer.JsonSerializer
使用すべきではありません。
offset() - クラス org.springframework.kafka.listener.adapter のメソッド。ConsumerRecordMetadata
OFFSET - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd
失敗したレコードのオフセット。
OFFSET - Static variable in class org.springframework.kafka.support.KafkaHeaders
パーティションオフセットのヘッダー。
OffsetAndMetadataProvider - Interface in org.springframework.kafka.listener
OffsetAndMetadata のプロバイダー。
offsetHeader(String) - クラス org.springframework.kafka.listener のメソッド。DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
元のレコードのオフセットを格納するために使用されるヘッダーの名前を設定します。
onAcknowledgement(RecordMetadata, Exception) - クラス org.springframework.kafka.support のメソッド。CompositeProducerInterceptor
onApplicationEvent(ContextRefreshedEvent) - クラス org.springframework.kafka.config のメソッド。KafkaListenerEndpointRegistry
onApplicationEvent(ContextRefreshedEvent) - クラス org.springframework.kafka.retrytopic のメソッド。DefaultDestinationTopicResolver
onApplicationEvent(ContextStoppedEvent) - クラス org.springframework.kafka.core のメソッド。DefaultKafkaProducerFactory
onApplicationEvent(ContextStoppedEvent) - クラス org.springframework.kafka.core のメソッド。KafkaTemplate
onApplicationEvent(ListenerContainerIdleEvent) - クラス org.springframework.kafka.listener のメソッド。ContainerGroupSequencer
onComplete(Map<TopicPartition, OffsetAndMetadata>, Exception) - クラス org.springframework.kafka.listener のメソッド。LoggingCommitCallback
onError(ProducerRecord<K, V>, RecordMetadata, Exception) - クラス org.springframework.kafka.support のメソッド。CompositeProducerListener
onError(ProducerRecord<K, V>, RecordMetadata, Exception) - クラス org.springframework.kafka.support のメソッド。LoggingProducerListener
onError(ProducerRecord<K, V>, RecordMetadata, Exception) - インターフェース org.springframework.kafka.support のメソッド。ProducerListener
メッセージの送信に失敗した後に呼び出されます。
onFirstPoll() - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware
手動パーティション割り当てを使用する場合、最初のポーリングが完了したときに呼び出されます。auto.offset.reset=latest を使用していて、初期位置が確立されるまで待つ必要がある場合に便利です。
onFirstPoll() - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate
onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractDelegatingMessageListenerAdapter
onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter
onIdleContainer(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware
コンテナーがアイドルコンテナーイベントを発行するように構成されている場合、このメソッドはコンテナーアイドルイベントが発行されたときに呼び出され、シーク操作を許可します。
onMessage(List<ConsumerRecord<K, Collection<ConsumerRecord<K, R>>>>, Consumer<?, ?>) - クラス org.springframework.kafka.requestreply のメソッド。AggregatingReplyingKafkaTemplate
onMessage(List<ConsumerRecord<K, R>>) - クラス org.springframework.kafka.requestreply のメソッド。ReplyingKafkaTemplate
onMessage(List<ConsumerRecord<K, V>>) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringBatchMessageListenerAdapter
onMessage(List<ConsumerRecord<K, V>>) - インターフェース org.springframework.kafka.listener のメソッド。BatchAcknowledgingConsumerAwareMessageListener
kafka からのデータで呼び出されます。
onMessage(List<ConsumerRecord<K, V>>) - インターフェース org.springframework.kafka.listener のメソッド。BatchAcknowledgingMessageListener
kafka からのデータで呼び出されます。
onMessage(List<ConsumerRecord<K, V>>) - インターフェース org.springframework.kafka.listener のメソッド。BatchConsumerAwareMessageListener
kafka からのデータで呼び出されます。
onMessage(List<ConsumerRecord<K, V>>, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringBatchMessageListenerAdapter
onMessage(List<ConsumerRecord<K, V>>, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。BatchConsumerAwareMessageListener
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringBatchMessageListenerAdapter
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment) - インターフェース org.springframework.kafka.listener のメソッド。BatchAcknowledgingMessageListener
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter
Kafka MessageListener エントリポイント。
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringBatchMessageListenerAdapter
onMessage(List<ConsumerRecord<K, V>>, Acknowledgment, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。BatchAcknowledgingConsumerAwareMessageListener
onMessage(ConsumerRecord<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。AcknowledgingConsumerAwareMessageListener
kafka からのデータで呼び出されます。
onMessage(ConsumerRecord<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。AcknowledgingMessageListener
kafka からのデータで呼び出されます。
onMessage(ConsumerRecord<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。AcknowledgingShareConsumerAwareMessageListener
onMessage(ConsumerRecord<K, V>) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringMessageListenerAdapter
onMessage(ConsumerRecord<K, V>) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaBackoffAwareMessageListenerAdapter
onMessage(ConsumerRecord<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareMessageListener
kafka からのデータで呼び出されます。
onMessage(ConsumerRecord<K, V>, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaBackoffAwareMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareMessageListener
onMessage(ConsumerRecord<K, V>, Acknowledgment) - インターフェース org.springframework.kafka.listener のメソッド。AcknowledgingMessageListener
kafka からのデータで呼び出されます。
onMessage(ConsumerRecord<K, V>, Acknowledgment) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Acknowledgment) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaBackoffAwareMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。AcknowledgingConsumerAwareMessageListener
onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。FilteringMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。KafkaBackoffAwareMessageListenerAdapter
onMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。RecordMessagingMessageListenerAdapter
Kafka AcknowledgingConsumerAwareMessageListener エントリポイント。
onMessage(ConsumerRecord, Acknowledgment, Consumer) - クラス org.springframework.kafka.listener.adapter のメソッド。ConvertingMessageListener
onMessage(ConsumerRecords<K, V>, Acknowledgment, Consumer<K, V>) - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter
onMessage(ConsumerRecords<K, V>, Acknowledgment, Consumer<K, V>) - インターフェース org.springframework.kafka.listener のメソッド。BatchMessageListener
リスナーは、ConsumerRecord のリストの代わりに、元の ConsumerRecords オブジェクトを受け取ります。
onMessage(T) - インターフェース org.springframework.kafka.listener のメソッド。GenericMessageListener
kafka からのデータで呼び出されます。
onMessage(T, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。GenericMessageListener
kafka からのデータで呼び出され、Consumer へのアクセスを提供します。
onMessage(T, Acknowledgment) - インターフェース org.springframework.kafka.listener のメソッド。GenericMessageListener
kafka からのデータで呼び出されます。
onMessage(T, Acknowledgment, Consumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。GenericMessageListener
kafka からのデータで呼び出され、Consumer へのアクセスを提供します。
onNextBackOff(MessageListenerContainer, Exception, long) - インターフェース org.springframework.kafka.listener のメソッド。BackOffHandler
次のバックオフを実行します。
onNextBackOff(MessageListenerContainer, Exception, long) - クラス org.springframework.kafka.listener のメソッド。ContainerPausingBackOffHandler
onNextBackOff(MessageListenerContainer, Exception, long) - クラス org.springframework.kafka.listener のメソッド。DefaultBackOffHandler
onNextBackOff(MessageListenerContainer, TopicPartition, long) - インターフェース org.springframework.kafka.listener のメソッド。BackOffHandler
パーティションの次のバックオフを実行します。
onNextBackOff(MessageListenerContainer, TopicPartition, long) - クラス org.springframework.kafka.listener のメソッド。ContainerPausingBackOffHandler
onPartitionsAssigned(Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractDelegatingMessageListenerAdapter
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter
onPartitionsAssigned(Map<TopicPartition, Long>, ConsumerSeekAware.ConsumerSeekCallback) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware
グループ管理を使用する場合。パーティションの割り当てが変更されたときに呼び出されます。
onPartitionsAssigned(Consumer<?, ?>, Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
ConsumerAwareRebalanceListener.onPartitionsAssigned(Collection) と同じですが、コンシューマーパラメーターが追加されています。
onPartitionsAssigned(Consumer<?, ?>, Collection<TopicPartition>, Runnable) - インターフェース org.springframework.kafka.listener のメソッド。CommonErrorHandler
パーティションが割り当てられたときに呼び出されます。
onPartitionsAssigned(Consumer<?, ?>, Collection<TopicPartition>, Runnable) - クラス org.springframework.kafka.listener のメソッド。DefaultErrorHandler
onPartitionsLost(Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
onPartitionsLost(Consumer<?, ?>, Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
ConsumerAwareRebalanceListener.onPartitionsLost(Collection) と同じですが、コンシューマーパラメーターが追加されています。
onPartitionsRevoked(Collection<TopicPartition>) - クラス org.springframework.kafka.listener のメソッド。AbstractConsumerSeekAware
onPartitionsRevoked(Collection<TopicPartition>) - クラス org.springframework.kafka.listener.adapter のメソッド。AbstractDelegatingMessageListenerAdapter
onPartitionsRevoked(Collection<TopicPartition>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter
onPartitionsRevoked(Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerSeekAware
グループ管理を使用する場合。パーティションの割り当てが取り消されたときに呼び出されます。
onPartitionsRevoked(Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
onPartitionsRevokedAfterCommit(Consumer<?, ?>, Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
ConsumerAwareRebalanceListener.onPartitionsRevoked(Collection) と同じですが、コンシューマーパラメーターが追加されています。
onPartitionsRevokedBeforeCommit(Consumer<?, ?>, Collection<TopicPartition>) - インターフェース org.springframework.kafka.listener のメソッド。ConsumerAwareRebalanceListener
ConsumerAwareRebalanceListener.onPartitionsRevoked(Collection) と同じですが、コンシューマーパラメーターが追加されています。
onSend(ProducerRecord<K, V>) - クラス org.springframework.kafka.support のメソッド。CompositeProducerInterceptor
onShareRecord(ConsumerRecord<K, V>, ShareAcknowledgment, ShareConsumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。ShareRecordMessagingMessageListenerAdapter
Kafka AcknowledgingConsumerAwareMessageListener エントリポイント。
onShareRecord(ConsumerRecord<K, V>, ShareAcknowledgment, ShareConsumer<?, ?>) - インターフェース org.springframework.kafka.listener のメソッド。AcknowledgingShareConsumerAwareMessageListener
Kafka からのデータ、確認応答とともに呼び出され、コンシューマーへのアクセスを提供します。
onSuccess(ProducerRecord<K, V>, RecordMetadata) - クラス org.springframework.kafka.support のメソッド。CompositeProducerListener
onSuccess(ProducerRecord<K, V>, RecordMetadata) - インターフェース org.springframework.kafka.support のメソッド。ProducerListener
メッセージの送信が成功した後 (つまり、ブローカーによって確認された後) に呼び出されます。
onTopOf(KStream<K, V>) - クラス org.springframework.kafka.support のメソッド。KafkaStreamBrancher
指定された KStream の上にブランチを構築する終了メソッド。
OPTIONAL - Enum constant in enum class org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer.ControlFlag
オプション - LoginModule は成功する必要はありません。
org.springframework.kafka - パッケージ org.springframework.kafka
kafka の基本パッケージ
org.springframework.kafka.annotation - パッケージ org.springframework.kafka.annotation
kafka アノテーションのパッケージ
org.springframework.kafka.aot - パッケージ org.springframework.kafka.aot
Spring AOT をサポートするクラスを提供します。
org.springframework.kafka.config - パッケージ org.springframework.kafka.config
kafka 構成のパッケージ
org.springframework.kafka.core - パッケージ org.springframework.kafka.core
kafka コアコンポーネントのパッケージ
org.springframework.kafka.event - パッケージ org.springframework.kafka.event
アプリケーションイベント。
org.springframework.kafka.listener - パッケージ org.springframework.kafka.listener
kafka リスナーのためのパッケージ
org.springframework.kafka.listener.adapter - パッケージ org.springframework.kafka.listener.adapter
リスナーを適応させるためのクラスを提供します。
org.springframework.kafka.mock - パッケージ org.springframework.kafka.mock
MockConsumer および MockProducer の使用をサポートするクラスを提供します。
org.springframework.kafka.requestreply - パッケージ org.springframework.kafka.requestreply
リクエスト / 応答セマンティクスのクラスを提供します。
org.springframework.kafka.retrytopic - パッケージ org.springframework.kafka.retrytopic
再試行可能なトピック処理用のパッケージ。
org.springframework.kafka.security.jaas - パッケージ org.springframework.kafka.security.jaas
jaas に関連するクラスを提供します。
org.springframework.kafka.streams - パッケージ org.springframework.kafka.streams
Kafka ストリームに関連するクラスのパッケージ。
org.springframework.kafka.streams.messaging - パッケージ org.springframework.kafka.streams.messaging
Kafka ストリームを使用した spring-messaging に関連するクラスのパッケージ。
org.springframework.kafka.support - パッケージ org.springframework.kafka.support
kafka サポート用パッケージ
org.springframework.kafka.support.converter - パッケージ org.springframework.kafka.support.converter
kafka コンバーター用パッケージ
org.springframework.kafka.support.mapping - パッケージ org.springframework.kafka.support.mapping
型マッピングに関連するクラスを提供します。
org.springframework.kafka.support.micrometer - パッケージ org.springframework.kafka.support.micrometer
Micrometer をサポートするクラスを提供します。
org.springframework.kafka.support.serializer - パッケージ org.springframework.kafka.support.serializer
Kafka 直列化に関連するクラスを提供します。
org.springframework.kafka.test - パッケージ org.springframework.kafka.test
EmbeddedKafka のトップレベル API を提供します。
org.springframework.kafka.test.assertj - パッケージ org.springframework.kafka.test.assertj
assertj 条件のクラスを提供します。
org.springframework.kafka.test.condition - パッケージ org.springframework.kafka.test.condition
JUnit5 条件のクラスを提供します。
org.springframework.kafka.test.context - パッケージ org.springframework.kafka.test.context
EmbeddedKafka コンテキストのカスタマイズ用のクラスを提供します。
org.springframework.kafka.test.core - パッケージ org.springframework.kafka.test.core
spring-kafka-test モジュールのコアパッケージ。
org.springframework.kafka.test.hamcrest - パッケージ org.springframework.kafka.test.hamcrest
ハムクレストマッチャーを提供します。
org.springframework.kafka.test.junit - パッケージ org.springframework.kafka.test.junit
spring-kafka-test で JUnit 固有の拡張機能を提供します。
org.springframework.kafka.test.utils - パッケージ org.springframework.kafka.test.utils
ユーティリティパッケージ。
org.springframework.kafka.transaction - パッケージ org.springframework.kafka.transaction
トランザクションに関連するクラスを提供します。
original() - クラス org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.Builder の静的メソッド
Original() - クラス org.springframework.kafka.listener のコンストラクター。DeadLetterPublishingRecoverer.HeaderNames.Builder.Original
ORIGINAL_CONSUMER_GROUP - Static variable in class org.springframework.kafka.support.KafkaHeaders
別のトピックに公開されたレコードを消費できなかったコンシューマーグループ。
ORIGINAL_OFFSET - Static variable in class org.springframework.kafka.support.KafkaHeaders
別のトピックに公開されたレコードの元のオフセット。
ORIGINAL_PARTITION - Static variable in class org.springframework.kafka.support.KafkaHeaders
別のトピックに公開されたレコードの元のパーティション。
ORIGINAL_TIMESTAMP - Static variable in class org.springframework.kafka.support.KafkaHeaders
別のトピックに公開されたレコードの元のタイムスタンプ。
ORIGINAL_TIMESTAMP_TYPE - Static variable in class org.springframework.kafka.support.KafkaHeaders
別のトピックに公開されたレコードの元のタイムスタンプ型。
ORIGINAL_TOPIC - Static variable in class org.springframework.kafka.support.KafkaHeaders
別のトピックに公開されたレコードの元のトピック。
A B C D E F G H I J K L M N O P R S T U V W
すべてのクラスとインターフェース | すべてのパッケージ | 定数フィールド値 | 連載形式