KafkaInboundGatewaySpec (Spring Integration API)

java.lang.ObjectSE
- org.springframework.beans.factory.config.AbstractFactoryBean<T>
- - org.springframework.integration.dsl.IntegrationComponentSpec<S,G>
  - - org.springframework.integration.dsl.MessagingGatewaySpec<S,KafkaInboundGateway<K,V,R>>
    - - org.springframework.integration.kafka.dsl.KafkaInboundGatewaySpec<K,V,R,S>

型パラメーター:
K - 鍵の型。
V - リクエスト値型。
R - 応答値の型。
S - ターゲット KafkaInboundGatewaySpec 実装型。
実装されているすべてのインターフェース:
Aware, BeanClassLoaderAware, BeanFactoryAware, DisposableBean, FactoryBean<KafkaInboundGateway<K,V,R>>, InitializingBean, Lifecycle, Phased, SmartLifecycle, ComponentsRegistration
既知の直属サブクラス
KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec
```
public class KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>>
extends MessagingGatewaySpec<S,KafkaInboundGateway<K,V,R>>
implements ComponentsRegistration
```
KafkaInboundGateway の MessagingGatewaySpec 実装。
導入:
5.4
作成者:
Gary Russell, Artem Bilan

ネストされたクラスの要約

ネストされたクラス
修飾子と型	クラスと説明
`static class`	`KafkaInboundGatewaySpec.KafkaInboundGatewayListenerContainerSpec<K, V, R>` `ConcurrentMessageListenerContainer` 構成の `KafkaInboundGatewaySpec` 拡張。

フィールドのサマリー
- クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたフィールド
  PARSER, target
- クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたフィールド
  logger
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE
- インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド
  OBJECT_TYPE_ATTRIBUTE

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`MapSE<ObjectSE, StringSE>`	`getComponentsToRegister()`
`S`	`messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)` レコードコンバーターを使用するようにメッセージコンバーターを設定します。
`S`	`onPartitionsAssignedSeekCallback(java.util.function.BiConsumerSE<MapSE<org.apache.kafka.common.TopicPartition,LongSE>,org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback> onPartitionsAssignedCallback)` `KafkaMessageListenerContainer` からの `ConsumerSeekAware.ConsumerSeekCallback#onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback)` 呼び出し中にシーク管理用の `BiConsumer`SE を指定します。
`S`	`recoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)` 再試行操作用の `RecoveryCallback` インスタンス。null の場合、再試行が終了した後に例外がコンテナーにスローされます。
`S`	`retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)` `KafkaInboundGateway.IntegrationRecordMessageListener` を `RetryingMessageListenerAdapter` にラップする `RetryTemplate` インスタンスを指定します。

クラス org.springframework.integration.dsl.MessagingGatewaySpec から継承されたメソッド
autoStartup, errorChannel, errorChannel, errorOnTimeout, id, phase, replyChannel, replyChannel, replyMapper, replyTimeout, requestChannel, requestChannel, requestMapper, requestTimeout, shouldTrack

クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたメソッド
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたメソッド
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE

- メソッドの詳細
  - messageConverter
```
public S messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
```
    レコードコンバーターを使用するようにメッセージコンバーターを設定します。
    パラメーター:
    messageConverter - コンバーター。
    戻り値:
    スペック
  - retryTemplate
```
public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
```
    KafkaInboundGateway.IntegrationRecordMessageListener を RetryingMessageListenerAdapter にラップする RetryTemplate インスタンスを指定します。
    パラメーター:
    retryTemplate - 使用する RetryTemplate。
    戻り値:
    スペック
  - recoveryCallback
```
public S recoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)
```
    再試行操作用の RecoveryCallback インスタンス。null の場合、再試行が終了した後に例外がコンテナーにスローされます。retryTemplate(RetryTemplate) が指定されていない場合は意味がありません。
    パラメーター:
    recoveryCallback - リカバリコールバック。
    戻り値:
    スペック
  - onPartitionsAssignedSeekCallback
```
public S onPartitionsAssignedSeekCallback(java.util.function.BiConsumerSE<MapSE<org.apache.kafka.common.TopicPartition,LongSE>,org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback> onPartitionsAssignedCallback)
```
    KafkaMessageListenerContainer からの ConsumerSeekAware.ConsumerSeekCallback#onPartitionsAssigned(Map, ConsumerSeekAware.ConsumerSeekCallback) 呼び出し中にシーク管理用の BiConsumerSE を指定します。
    パラメーター:
    onPartitionsAssignedCallback - 使用する BiConsumerSE
    戻り値:
    スペック
    導入:
    3.0.4
  - getComponentsToRegister
```
public MapSE<ObjectSE,StringSE> getComponentsToRegister()
```
    次で指定:
    インターフェース ComponentsRegistration の getComponentsToRegister

クラス KafkaInboundGatewaySpec<K,V,R,S extends KafkaInboundGatewaySpec<K,V,R,S>>

ネストされたクラスの要約

フィールドのサマリー

クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたフィールド

クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたフィールド

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

インターフェース org.springframework.beans.factory.FactoryBean から継承されたフィールド

メソッドのサマリー

クラス org.springframework.integration.dsl.MessagingGatewaySpec から継承されたメソッド

クラス org.springframework.integration.dsl.IntegrationComponentSpec から継承されたメソッド

クラス org.springframework.beans.factory.config.AbstractFactoryBean から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

メソッドの詳細

messageConverter

retryTemplate

recoveryCallback

onPartitionsAssignedSeekCallback

getComponentsToRegister