インデックス

T

targetType - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer

TEMPLATE_OBSERVATION - Enum constant in enum class org.springframework.kafka.support.micrometer.KafkaTemplateObservation

KafkaTemplates の観測。

testPlanExecutionFinished(TestPlan) - クラス org.springframework.kafka.test.junit のメソッド。GlobalEmbeddedKafkaTestExecutionListener

testPlanExecutionStarted(TestPlan) - クラス org.springframework.kafka.test.junit のメソッド。GlobalEmbeddedKafkaTestExecutionListener

ThreadStateProcessor - Interface in org.springframework.kafka.listener

Consumer が使用可能な場合に、スレッドにバインドされたリソースを管理するための一般的なインターフェース。

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

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

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

メッセージの再試行が断念され、メッセージが DLT に送信されるまでのミリ秒単位の時間。

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

ミリ秒単位でグローバルタイムアウトを構成します。その後、リスナーが次に例外をスローしたときにレコードが DLT に直接送信されます。

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

timestamp(long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

timestamp(TimestampType, long) - Static method in class org.springframework.kafka.test.assertj.KafkaConditions

TIMESTAMP - Enum constant in enum class org.springframework.kafka.support.TopicPartitionOffset.SeekPosition

タイムスタンプを探します。タイムスタンプ以上のタイムスタンプを持つレコードが存在しない場合は、最後までシークします。

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

プロデューサーレコードのタイムスタンプを保持するためのヘッダー。

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

タイムスタンプの type を保持するためのヘッダー。

TimestampedException - Exception in org.springframework.kafka.listener

スローされたときのタイムスタンプを記録する KafkaException。

TimestampedException(Exception) - Constructor for exception org.springframework.kafka.listener.TimestampedException

指定された原因と現在の時刻を使用してインスタンスを構築します。

TimestampedException(Exception, long) - Constructor for exception org.springframework.kafka.listener.TimestampedException

スローされたときのタイムスタンプとその原因を使用してインスタンスを作成します。

TimestampedException(Exception, Instant) - Constructor for exception org.springframework.kafka.listener.TimestampedException

スローされたときのインスタントとその原因を使用してインスタンスを作成します。

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

元のレコードのタイムスタンプを格納するために使用されるヘッダーの名前を設定します。

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

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

元のレコードの timestampType を格納するために使用されるヘッダーの名前を設定します。

toClass(Headers) - インターフェース org.springframework.kafka.support.mapping のメソッド。ClassMapper

toClass(Headers) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper

ToFromStringSerde< T > - Class in org.springframework.kafka.support.serializer

ToStringSerializer および ParseStringDeserializer に委譲する Serde。

ToFromStringSerde(ToStringSerializer<T>, ParseStringDeserializer<T>) - クラス org.springframework.kafka.support.serializer. ToFromStringSerde のコンストラクター

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

toHeaders(Headers, Map<String, Object>) - クラス org.springframework.kafka.support のメソッド。DefaultKafkaHeaderMapper

toHeaders(Headers, Map<String, Object>) - インターフェース org.springframework.kafka.support のメソッド。KafkaHeaderMapper

指定されたネイティブヘッダーから、最終的な MessageHeaders のヘッダーのマップにマップします。

toHeaders(Headers, Map<String, Object>) - クラス org.springframework.kafka.support のメソッド。SimpleKafkaHeaderMapper

toJavaType(Headers) - クラス org.springframework.kafka.support.mapping のメソッド。DefaultJackson2JavaTypeMapper

toJavaType(Headers) - インターフェース org.springframework.kafka.support.mapping のメソッド。Jackson2JavaTypeMapper

toMessage(List<ConsumerRecord<?, ?>>, Acknowledgment, Consumer<?, ?>, Type) - インターフェース org.springframework.kafka.support.converter のメソッド。BatchMessageConverter

ConsumerRecord のリストを Message に変換します。

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

toMessage(ConsumerRecord<?, ?>, Acknowledgment, Consumer<?, ?>, Type) - クラス org.springframework.kafka.support.converter のメソッド。MessagingMessageConverter

toMessage(ConsumerRecord<?, ?>, Acknowledgment, Consumer<?, ?>, Type) - インターフェース org.springframework.kafka.support.converter のメソッド。RecordMessageConverter

ConsumerRecord を Message に変換します。

toMessagingMessage(List, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。BatchMessagingMessageListenerAdapter

toMessagingMessage(ConsumerRecord<K, V>, Acknowledgment, Consumer<?, ?>) - クラス org.springframework.kafka.listener.adapter のメソッド。MessagingMessageListenerAdapter

topic() - Element in annotation interface org.springframework.kafka.annotation.TopicPartition

耳を傾けるトピック。

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

TOPIC - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

失敗したレコードの元のトピック。

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

Kafka にデータを送信するときのトピックを含むヘッダー。

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

NewTopic のビルダー。

TopicForRetryable - org.springframework.kafka.support のクラス

この NewTopic が再試行可能なトピック用であることを示すマーカー。通常の NewTopic が存在する場合、管理者はこれらを無視します。

TopicForRetryable(String, int, short) - クラス org.springframework.kafka.support. TopicForRetryable のコンストラクター

提供されたプロパティでインスタンスを作成します。

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

元のレコードのトピックを格納するために使用されるヘッダーの名前を設定します。

TopicPartition - Annotation Interface in org.springframework.kafka.annotation

トピック / パーティション情報を KafkaListener に追加するために使用されます。

TopicPartitionOffset - org.springframework.kafka.support のクラス

トピック名、パーティション番号、オプションでそのオフセットを表す構成コンテナー。

TopicPartitionOffset(String, int) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

初期オフセット管理なしでインスタンスを構築します。

TopicPartitionOffset(String, int, Long) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

TopicPartitionOffset.isRelativeToCurrent() false で指定された初期オフセットを使用してインスタンスを構築します。

TopicPartitionOffset(String, int, Long, boolean) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

指定された初期オフセットを使用してインスタンスを構築します。

TopicPartitionOffset(String, int, Long, TopicPartitionOffset.SeekPosition) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

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

TopicPartitionOffset(String, int, Function<Long, Long>) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

オフセットを計算するために提供された関数を使用してインスタンスを構築します。

TopicPartitionOffset(String, int, TopicPartitionOffset.SeekPosition) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

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

TopicPartitionOffset(TopicPartition, Long, TopicPartitionOffset.SeekPosition) - クラス org.springframework.kafka.support. TopicPartitionOffset のコンストラクター

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

TopicPartitionOffset.SeekPosition - org.springframework.kafka.support の Enum クラス

「特別な」シークの列挙。

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

手動のトピック / パーティション割り当てを使用する場合のこのリスナーの topicPartitions。

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

このリスナーのトピックパターン。

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

このリスナーのトピック。

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

作成する必要のあるトピックトピックには、プロパティプレースホルダーが含まれる場合があります。

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

組み込みブローカーで作成するトピック。

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

再試行トピックの末尾に、そのトピックの遅延値を付けるか、単純なインデックスを付けるか。

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

RetryTopic 機能の定数。

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

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

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerFailedToStartEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerPartitionPausedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerPartitionResumedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerPausedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerResumedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerRetryAuthEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerRetryAuthSuccessfulEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerStartedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerStartingEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerStoppedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ConsumerStoppingEvent

toString() - クラス org.springframework.kafka.event のメソッド。ContainerStoppedEvent

toString() - クラス org.springframework.kafka.event のメソッド。ListenerContainerIdleEvent

toString() - クラス org.springframework.kafka.event のメソッド。ListenerContainerNoLongerIdleEvent

toString() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionIdleEvent

toString() - クラス org.springframework.kafka.event のメソッド。ListenerContainerPartitionNoLongerIdleEvent

toString() - クラス org.springframework.kafka.event のメソッド。NonResponsiveConsumerEvent

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

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

このレコードクラスの文字列表現を返します。

toString() - Method in record class org.springframework.kafka.listener.adapter.MessagingMessageListenerAdapter.ReplyExpressionRoot

このレコードクラスの文字列表現を返します。

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

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

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

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

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

toString() - クラス org.springframework.kafka.requestreply のメソッド。CorrelationKey

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

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

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

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

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

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

toString() - クラス org.springframework.kafka.test.core のメソッド。BrokerAddress

ToStringSerializer< T > - Class in org.springframework.kafka.support.serializer

エンティティの直列化された表現を取得するために Object.toString() に依存する汎用 Serializer。

ToStringSerializer() - クラス org.springframework.kafka.support.serializer. ToStringSerializer のコンストラクター

TRACE - Enum constant in enum class org.springframework.kafka.KafkaException.Level

トレース。

TRACE - Enum constant in enum class org.springframework.kafka.support.LogIfLevelEnabled.Level

トレース。

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

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

ファクトリがトランザクションをサポートしている場合は true を返します。

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

TransactionIdSuffixStrategy - Interface in org.springframework.kafka.core

トランザクションプロデューサーサフィックスを管理するための戦略。

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

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

キャプチャーされた例外をトラバースして、上記の例外を探す必要があるかどうか。

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

原因 チェーン をトラバースするように分類子を構成します。

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

原因 チェーン をトラバースするか、トラバースしないように分類子を構成します。

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

TRUSTED_PACKAGES - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

信頼できる逆直列化パッケージの Kafka 構成プロパティ。

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

信頼できるパッケージをデフォルトの型マッパーに追加します。

TS - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

失敗したレコードのタイムスタンプ。

TS_TYPE - Enum constant in enum class org.springframework.kafka.listener.DeadLetterPublishingRecoverer.HeaderNames.HeadersToAdd

失敗したレコードのタイムスタンプ型。

TYPE_ID - Enum constant in enum class org.springframework.kafka.support.mapping.Jackson2JavaTypeMapper.TypePrecedence

型はヘッダーから取得されます。

TYPE_MAPPINGS - Static variable in class org.springframework.kafka.support.serializer.JsonDeserializer

型マッパーに型マッピングを追加するための Kafka 構成プロパティ: 'foo=com.Foo、bar = com.Bar'。

TYPE_MAPPINGS - Static variable in class org.springframework.kafka.support.serializer.JsonSerializer

型マッパーに型マッピングを追加するための Kafka 構成プロパティ: 'foo:com.Foo、bar:com.Bar'。

typeFunction(BiFunction<byte[], Headers, JavaType>) - クラス org.springframework.kafka.support.serializer のメソッド。JsonDeserializer

デシリアライズするデータとヘッダーを受け取り、JavaType を返す BiFunctionSE を設定します。

typeMapper - Variable in class org.springframework.kafka.support.serializer.JsonDeserializer

typeMapper - Variable in class org.springframework.kafka.support.serializer.JsonSerializer

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

付属の Jackson2JavaTypeMapper を使用してください。

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

付属の Jackson2JavaTypeMapper を使用してください。

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

付属の Jackson2JavaTypeMapper を使用してください。

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

デシリアライズするデータとヘッダーを受け取り、JavaType を返す JsonTypeResolver を設定します。