クラス RoutingKafkaTemplate
java.lang.ObjectSE
org.springframework.kafka.core.KafkaTemplate<ObjectSE,ObjectSE>
org.springframework.kafka.core.RoutingKafkaTemplate
- 実装されたすべてのインターフェース:
EventListenerSE、Aware、BeanNameAware、DisposableBean、SmartInitializingSingleton、ApplicationContextAware、ApplicationListener<ContextStoppedEvent>、KafkaOperations<ObjectSE,ObjectSE>
トピック名に基づいてメッセージをルーティングする
KafkaTemplate。トランザクション、flush()、metrics()、execute(org.springframework.kafka.core.KafkaOperations.ProducerCallback) をサポートせず、単純な送信操作のみをサポートします。- 導入:
- 2.5
- 作成者:
- Gary Russell, Nathan Xu
ネストされたクラスのサマリー
インターフェース org.springframework.kafka.core.KafkaOperations から継承されたネストクラス / インターフェース
KafkaOperations.OperationsCallback<K,V, T>, KafkaOperations.ProducerCallback<K, V, T> フィールドのサマリー
クラス org.springframework.kafka.core.KafkaTemplate から継承されたフィールド
loggerインターフェース org.springframework.kafka.core.KafkaOperations から継承されたフィールド
DEFAULT_POLL_TIMEOUTコンストラクターの概要
コンストラクターコンストラクター説明RoutingKafkaTemplate(MapSE<PatternSE, ProducerFactory<ObjectSE, ObjectSE>> factories) 提供されたプロパティを使用してインスタンスを構築します。メソッドのサマリー
修飾子と型メソッド説明<T> Texecute(KafkaOperations.ProducerCallback<ObjectSE, ObjectSE, T> callback) プロデューサーで任意の操作を実行し、結果を返します。<T> T操作に対して任意の操作を実行し、結果を返します。voidflush()プロデューサーをフラッシュします。このテンプレートで使用されるプロデューサーファクトリを返します。getProducerFactory(StringSE topic) トピックに基づいて、このテンプレートで使用されるプロデューサーファクトリを返します。MapSE<org.apache.kafka.common.MetricName,? extends org.apache.kafka.common.Metric> metrics()Producer.metrics()を参照してください。voidsendOffsetsToTransaction(MapSE<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata) トランザクションで実行する場合は、コンシューマーオフセットをトランザクションに送信します。クラス org.springframework.kafka.core.KafkaTemplate から継承されたメソッド
afterSingletonsInstantiated, closeProducer, clusterId, destroy, doSend, getDefaultTopic, getKafkaAdmin, getMessageConverter, getMicrometerTagsProvider, getObservationRegistry, getTheProducer, getTransactionIdPrefix, inTransaction, isAllowNonTransactional, isTransactional, onApplicationEvent, partitionsFor, receive, receive, send, send, send, send, send, send, sendDefault, sendDefault, sendDefault, sendDefault, setAllowNonTransactional, setApplicationContext, setBeanName, setCloseTimeout, setConsumerFactory, setDefaultTopic, setKafkaAdmin, setMessageConverter, setMessagingConverter, setMicrometerEnabled, setMicrometerTags, setMicrometerTagsProvider, setObservationConvention, setObservationEnabled, setObservationRegistry, setProducerInterceptor, setProducerListener, setTransactionIdPrefixクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSEインターフェース org.springframework.context.ApplicationListener から継承されたメソッド
supportsAsyncExecutionインターフェース org.springframework.kafka.core.KafkaOperations から継承されたメソッド
receive, receive
コンストラクターの詳細
RoutingKafkaTemplate
提供されたプロパティでインスタンスを構築します。トピックパターンは順番にトラバースされるため、LinkedHashMapSE などの順序付きマップを使用して、より具体的なパターンを最初に宣言する必要があります。- パラメーター:
factories- ファクトリ。
メソッドの詳細
getProducerFactory
クラスからコピーされた説明:KafkaTemplateこのテンプレートで使用されるプロデューサーファクトリを返します。- 次で指定:
- インターフェース
KafkaOperations<ObjectSE,のObjectSE> getProducerFactory - オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> getProducerFactory - 戻り値:
- ファクトリ。
getProducerFactory
クラスからコピーされた説明:KafkaTemplateトピックに基づいて、このテンプレートで使用されるプロデューサーファクトリを返します。デフォルトの実装は、唯一のプロデューサーファクトリを返します。- オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> getProducerFactory - パラメーター:
topic- トピック。- 戻り値:
- ファクトリ。
execute
インターフェースからコピーされた説明:KafkaOperationsプロデューサーで任意の操作を実行し、結果を返します。- 次で指定:
- インターフェース
KafkaOperations<ObjectSE,のObjectSE> execute - オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> execute - 型パラメーター:
T- 結果の型。- パラメーター:
callback- コールバック。- 戻り値:
- 結果。
executeInTransaction
インターフェースからコピーされた説明:KafkaOperations操作に対して任意の操作を実行し、結果を返します。操作はローカルトランザクション内で呼び出され、グローバルトランザクション (存在する場合) には参加しません。- 次で指定:
- インターフェース
KafkaOperations<ObjectSE,のObjectSE> executeInTransaction - オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> executeInTransaction - 型パラメーター:
T- 結果の型。- パラメーター:
callback- コールバック。- 戻り値:
- 結果。
sendOffsetsToTransaction
public void sendOffsetsToTransaction(MapSE<org.apache.kafka.common.TopicPartition, org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, org.apache.kafka.clients.consumer.ConsumerGroupMetadata groupMetadata) インターフェースからコピーされた説明:KafkaOperationsトランザクションで実行する場合、コンシューマーオフセットをトランザクションに送信します。操作がリスナーコンテナースレッドで呼び出された場合 (およびリスナーコンテナーがKafkaAwareTransactionManagerで構成されている場合) は、コンテナーがトランザクションへのオフセットの送信を処理するため、このメソッドを呼び出す必要はありません。2.5 ブローカー以降で使用します。- 次で指定:
- インターフェース
KafkaOperations<ObjectSE,のObjectSE> sendOffsetsToTransaction - オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> sendOffsetsToTransaction - パラメーター:
offsets- オフセット。groupMetadata- コンシューマーグループのメタデータ。- 関連事項:
Producer.sendOffsetsToTransaction(Map, ConsumerGroupMetadata)
metrics
インターフェースからコピーされた説明:KafkaOperationsProducer.metrics()を参照してください。- 次で指定:
- インターフェース
KafkaOperations<ObjectSE,のObjectSE> metrics - オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> metrics - 戻り値:
- メトリクス。
flush
public void flush()クラスからコピーされた説明:KafkaTemplateプロデューサーをフラッシュします。注
ProducerFactoryがシングルトンプロデューサー (DefaultKafkaProducerFactoryなど) を提供する場合にのみ、このメソッドを呼び出すことが理にかなっています。- 次で指定:
- インターフェース
KafkaOperations<ObjectSE,のObjectSE> flush - オーバーライド:
- クラス
KafkaTemplate<ObjectSE,のObjectSE> flush