KafkaMessageDrivenChannelAdapterSpec (Spring Integration API)

java.lang.ObjectSE
- org.springframework.beans.factory.config.AbstractFactoryBean<T>
- - org.springframework.integration.dsl.IntegrationComponentSpec<S,P>
  - - org.springframework.integration.dsl.MessageProducerSpec<S,KafkaMessageDrivenChannelAdapter<K,V>>
    - - org.springframework.integration.kafka.dsl.KafkaMessageDrivenChannelAdapterSpec<K,V,S>

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

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

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

フィールドのサマリー
- クラス 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

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`S`	`ackDiscarded(boolean ackDiscarded)` `FilteringMessageListenerAdapter` が破棄されたレコードを確認する必要があるかどうかを示す `boolean` フラグ。
`S`	`batchMessageConverter(org.springframework.kafka.support.converter.BatchMessageConverter messageConverter)` メッセージコンバーターを設定して、バッチベースのコンシューマーで使用します。
`S`	`filterInRetry(boolean filterInRetry)` `RetryingMessageListenerAdapter` と `FilteringMessageListenerAdapter` の両方が存在する場合に、`RetryingMessageListenerAdapter` と `FilteringMessageListenerAdapter` が互いにラップされる順序を指定する `boolean` フラグ。
`MapSE<ObjectSE, StringSE>`	`getComponentsToRegister()`
`S`	`messageConverter(org.springframework.kafka.support.converter.MessageConverter messageConverter)` メッセージコンバーターを設定します。モードに応じて、`RecordMessageConverter` または `BatchMessageConverter` でなければなりません。
`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`	`payloadType(ClassSE<?> payloadType)` 型認識メッセージコンバーター（`StringJsonMessageConverter` など）を使用する場合は、コンバーターが作成するペイロード型を設定します。
`S`	`recordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K, V> recordFilterStrategy)` `KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener` を `FilteringMessageListenerAdapter` にラップする `RecordFilterStrategy` を指定します。
`S`	`recordMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)` レコードコンバーターを使用するようにメッセージコンバーターを設定します。
`S`	`recoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)` 再試行操作用の `RecoveryCallback` インスタンス。null の場合、再試行が終了した後に例外がコンテナーにスローされます。
`S`	`retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)` `KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener` を `RetryingMessageListenerAdapter` にラップする `RetryTemplate` インスタンスを指定します。

クラス org.springframework.integration.dsl.MessageProducerSpec から継承されたメソッド
autoStartup, errorChannel, errorChannel, errorMessageStrategy, id, outputChannel, outputChannel, phase, sendTimeout, 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.MessageConverter messageConverter)
```
    メッセージコンバーターを設定します。モードに応じて、RecordMessageConverter または BatchMessageConverter でなければなりません。
    パラメーター:
    messageConverter - コンバーター。
    戻り値:
    スペック
  - recordMessageConverter
```
public S recordMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
```
    レコードコンバーターを使用するようにメッセージコンバーターを設定します。
    パラメーター:
    messageConverter - コンバーター。
    戻り値:
    スペック
  - batchMessageConverter
```
public S batchMessageConverter(org.springframework.kafka.support.converter.BatchMessageConverter messageConverter)
```
    メッセージコンバーターを設定して、バッチベースのコンシューマーで使用します。
    パラメーター:
    messageConverter - コンバーター。
    戻り値:
    スペック
  - recordFilterStrategy
```
public S recordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy)
```
    KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener を FilteringMessageListenerAdapter にラップする RecordFilterStrategy を指定します。
    パラメーター:
    recordFilterStrategy - 使用する RecordFilterStrategy。
    戻り値:
    スペック
  - ackDiscarded
```
public S ackDiscarded(boolean ackDiscarded)
```
    FilteringMessageListenerAdapter が破棄されたレコードを確認する必要があるかどうかを示す boolean フラグ。recordFilterStrategy(RecordFilterStrategy) が指定されていない場合は意味がありません。
    パラメーター:
    ackDiscarded - 破棄されたメッセージに確認応答（コミットオフセット）する場合は true。
    戻り値:
    スペック
  - retryTemplate
```
public S retryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
```
    KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener を RetryingMessageListenerAdapter にラップする RetryTemplate インスタンスを指定します。
    パラメーター:
    retryTemplate - 使用する RetryTemplate。
    戻り値:
    スペック
  - recoveryCallback
```
public S recoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)
```
    再試行操作用の RecoveryCallback インスタンス。null の場合、再試行が終了した後に例外がコンテナーにスローされます。retryTemplate(RetryTemplate) が指定されていない場合は意味がありません。
    パラメーター:
    recoveryCallback - リカバリコールバック。
    戻り値:
    スペック
  - payloadType
```
public S payloadType(ClassSE<?> payloadType)
```
    型認識メッセージコンバーター（StringJsonMessageConverter など）を使用する場合、コンバーターが作成するペイロード型を設定します。デフォルトは ObjectSE です。
    パラメーター:
    payloadType - 型。
    戻り値:
    スペック
    導入:
    3.2.0
  - filterInRetry
```
public S filterInRetry(boolean filterInRetry)
```
    RetryingMessageListenerAdapter と FilteringMessageListenerAdapter の両方が存在する場合に、RetryingMessageListenerAdapter と FilteringMessageListenerAdapter が互いにラップされる順序を指定する boolean フラグ。RetryTemplate または RecordFilterStrategy のいずれか 1 つだけが存在する場合は意味がありません。
    パラメーター:
    filterInRetry - RetryingMessageListenerAdapter および FilteringMessageListenerAdapter 折り返しの順序。デフォルトは false です。
    戻り値:
    スペック
  - 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

クラス KafkaMessageDrivenChannelAdapterSpec<K,V,S extends KafkaMessageDrivenChannelAdapterSpec<K,V,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.MessageProducerSpec から継承されたメソッド

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

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

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

メソッドの詳細

messageConverter

recordMessageConverter

batchMessageConverter

recordFilterStrategy

ackDiscarded

retryTemplate

recoveryCallback

payloadType

filterInRetry

onPartitionsAssignedSeekCallback

getComponentsToRegister