KafkaMessageDrivenChannelAdapter (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.endpoint.AbstractEndpoint
  - - org.springframework.integration.endpoint.MessageProducerSupport
    - - org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter<K,V>

型パラメーター:
K - 鍵の型。
V - 値の型。
実装されているすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, OrderlyShutdownCapable, MessageProducer, Pausable, IntegrationPattern, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
```
public class KafkaMessageDrivenChannelAdapter<K,V>
extends MessageProducerSupport
implements OrderlyShutdownCapable, Pausable
```
メッセージ駆動型チャネルアダプター。
導入:
5.4
作成者:
Marius Bogoevici, Gary Russell, Artem Bilan, Urs Keller

ネストされたクラスの要約
ネストされたクラス
修飾子と型クラスと説明
static class KafkaMessageDrivenChannelAdapter.ListenerMode
コンテナー、レコード、バッチのリスナーモード。

ネストされたクラス
修飾子と型	クラスと説明
`static class`	`KafkaMessageDrivenChannelAdapter.ListenerMode` コンテナー、レコード、バッチのリスナーモード。

フィールドのサマリー
- クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
  lifecycleCondition, lifecycleLock
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE

コンストラクターの概要

コンストラクター
コンストラクターと説明
`KafkaMessageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K, V> messageListenerContainer)` モード `KafkaMessageDrivenChannelAdapter.ListenerMode.record` でインスタンスを作成します。
`KafkaMessageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K, V> messageListenerContainer, KafkaMessageDrivenChannelAdapter.ListenerMode mode)` 提供されたモードでインスタンスを構築します。

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`int`	`afterShutdown()` スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。
`int`	`beforeShutdown()` シャットダウンが始まる前に呼び出されます。
`protected void`	`doStart()` デフォルトでは何もしません。
`protected void`	`doStop()` デフォルトでは何もしません。
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`protected AttributeAccessor`	`getErrorMessageAttributes(Message<?> message)` `errorMessageStrategy` でエラーメッセージを作成するときに使用する `AttributeAccessor` を設定します。
`boolean`	`isPaused()` エンドポイントが一時停止しているかどうかを確認します。
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`pause()` エンドポイントを一時停止します。
`void`	`resume()` 一時停止した場合は、エンドポイントを再開します。
`void`	`setAckDiscarded(boolean ackDiscarded)` `FilteringMessageListenerAdapter` が破棄されたレコードを確認する必要があるかどうかを示す `boolean` フラグ。
`void`	`setBatchMessageConverter(org.springframework.kafka.support.converter.BatchMessageConverter messageConverter)` メッセージコンバーターを設定して、バッチベースのコンシューマーで使用します。
`void`	`setBindSourceRecord(boolean bindSourceRecord)` true に設定すると、`IntegrationMessageHeaderAccessor.SOURCE_DATA` という名前のヘッダーにソースコンシューマーレコードがバインドされます。
`void`	`setFilterInRetry(boolean filterInRetry)` `RetryingMessageListenerAdapter` と `FilteringMessageListenerAdapter` の両方が存在する場合に、`RetryingMessageListenerAdapter` と `FilteringMessageListenerAdapter` が互いにラップされる順序を指定する `boolean` フラグ。
`void`	`setMessageConverter(org.springframework.kafka.support.converter.MessageConverter messageConverter)` メッセージコンバーターを設定します。モードに応じて、`RecordMessageConverter` または `BatchMessageConverter` でなければなりません。
`void`	`setOnPartitionsAssignedSeekCallback(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 を指定します。
`void`	`setPayloadType(ClassSE<?> payloadType)` 型認識メッセージコンバーター（`StringJsonMessageConverter` など）を使用する場合は、コンバーターが作成するペイロード型を設定します。
`void`	`setRecordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K, V> recordFilterStrategy)` `KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener` を `FilteringMessageListenerAdapter` にラップする `RecordFilterStrategy` を指定します。
`void`	`setRecordMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)` レコードコンバーターを使用するようにメッセージコンバーターを設定します。
`void`	`setRecoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)` 再試行操作用の `RecoveryCallback` インスタンス。null の場合、再試行が終了した後、例外がコンテナーにスローされます（エラーチャネルが設定されていない場合）。
`void`	`setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)` `KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener` を `RetryingMessageListenerAdapter` にラップする `RetryTemplate` インスタンスを指定します。

クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

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

インターフェース org.springframework.integration.support.management.ManageableLifecycle から継承されたメソッド
isRunning, start, stop

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

- コンストラクターの詳細
  - KafkaMessageDrivenChannelAdapter
```
public KafkaMessageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> messageListenerContainer)
```
    モード KafkaMessageDrivenChannelAdapter.ListenerMode.record でインスタンスを作成します。
    パラメーター:
    messageListenerContainer - コンテナー。
  - KafkaMessageDrivenChannelAdapter
```
public KafkaMessageDrivenChannelAdapter(org.springframework.kafka.listener.AbstractMessageListenerContainer<K,V> messageListenerContainer,
                                        KafkaMessageDrivenChannelAdapter.ListenerMode mode)
```
    提供されたモードでインスタンスを構築します。
    パラメーター:
    messageListenerContainer - コンテナー。
    mode - モード。
    導入:
    1.2
- メソッドの詳細
  - setMessageConverter
```
public void setMessageConverter(org.springframework.kafka.support.converter.MessageConverter messageConverter)
```
    メッセージコンバーターを設定します。モードに応じて、RecordMessageConverter または BatchMessageConverter でなければなりません。
    パラメーター:
    messageConverter - コンバーター。
  - setRecordMessageConverter
```
public void setRecordMessageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
```
    レコードコンバーターを使用するようにメッセージコンバーターを設定します。
    パラメーター:
    messageConverter - コンバーター。
    導入:
    2.1
  - setBatchMessageConverter
```
public void setBatchMessageConverter(org.springframework.kafka.support.converter.BatchMessageConverter messageConverter)
```
    メッセージコンバーターを設定して、バッチベースのコンシューマーで使用します。
    パラメーター:
    messageConverter - コンバーター。
    導入:
    2.1
  - setRecordFilterStrategy
```
public void setRecordFilterStrategy(org.springframework.kafka.listener.adapter.RecordFilterStrategy<K,V> recordFilterStrategy)
```
    KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener を FilteringMessageListenerAdapter にラップする RecordFilterStrategy を指定します。
    パラメーター:
    recordFilterStrategy - 使用する RecordFilterStrategy。
    導入:
    2.0.1
  - setAckDiscarded
```
public void setAckDiscarded(boolean ackDiscarded)
```
    FilteringMessageListenerAdapter が破棄されたレコードを確認する必要があるかどうかを示す boolean フラグ。setRecordFilterStrategy(RecordFilterStrategy) が指定されていない場合は意味がありません。
    パラメーター:
    ackDiscarded - 破棄されたメッセージに確認応答（コミットオフセット）する場合は true。
    導入:
    2.0.1
  - setRetryTemplate
```
public void setRetryTemplate(org.springframework.retry.support.RetryTemplate retryTemplate)
```
    KafkaMessageDrivenChannelAdapter.IntegrationRecordMessageListener を RetryingMessageListenerAdapter にラップする RetryTemplate インスタンスを指定します。
    パラメーター:
    retryTemplate - 使用する RetryTemplate。
    導入:
    2.0.1
  - setRecoveryCallback
```
public void setRecoveryCallback(org.springframework.retry.RecoveryCallback<? extends ObjectSE> recoveryCallback)
```
    再試行操作用の RecoveryCallback インスタンス。null の場合、再試行が終了した後、例外がコンテナーにスローされます（エラーチャネルが設定されていない場合）。setRetryTemplate(RetryTemplate) が指定されていない場合は意味がありません。
    パラメーター:
    recoveryCallback - リカバリコールバック。
    導入:
    2.0.1
  - setFilterInRetry
```
public void setFilterInRetry(boolean filterInRetry)
```
    RetryingMessageListenerAdapter と FilteringMessageListenerAdapter の両方が存在する場合に、RetryingMessageListenerAdapter と FilteringMessageListenerAdapter が互いにラップされる順序を指定する boolean フラグ。RetryTemplate または RecordFilterStrategy のいずれか 1 つだけが存在する場合は意味がありません。
    パラメーター:
    filterInRetry - RetryingMessageListenerAdapter および FilteringMessageListenerAdapter 折り返しの順序。デフォルトは false です。
    導入:
    2.0.1
  - setPayloadType
```
public void setPayloadType(ClassSE<?> payloadType)
```
    型認識メッセージコンバーター（StringJsonMessageConverter など）を使用する場合、コンバーターが作成するペイロード型を設定します。デフォルトは ObjectSE です。
    パラメーター:
    payloadType - 型。
    導入:
    2.1.1
  - setOnPartitionsAssignedSeekCallback
```
public void setOnPartitionsAssignedSeekCallback(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 を指定します。これは、内部 MessagingMessageListenerAdapter 実装から呼び出されます。
    パラメーター:
    onPartitionsAssignedCallback - 使用する BiConsumerSE
    導入:
    3.0.4
    関連事項:
    ConsumerSeekAware.onPartitionsAssigned(java.util.Map<org.apache.kafka.common.TopicPartition, java.lang.Long>, org.springframework.kafka.listener.ConsumerSeekAware.ConsumerSeekCallback)
  - setBindSourceRecord
```
public void setBindSourceRecord(boolean bindSourceRecord)
```
    true に設定すると、IntegrationMessageHeaderAccessor.SOURCE_DATA という名前のヘッダーにソースコンシューマーレコードがバインドされます。バッチリスナーには適用されません。
    パラメーター:
    bindSourceRecord - バインドする場合は true。
    導入:
    3.1.4
  - getComponentType
```
public StringSE getComponentType()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
    次で指定:
    インターフェース NamedComponent の getComponentType
    オーバーライド:
    クラス IntegrationObjectSupport の getComponentType
  - onInit
```
protected void onInit()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスは、初期化ロジック用にこれを実装できます。
    オーバーライド:
    クラス MessageProducerSupport の onInit
  - doStart
```
protected void doStart()
```
    クラスからコピーされた説明: MessageProducerSupport
    デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
    オーバーライド:
    クラス MessageProducerSupport の doStart
  - doStop
```
protected void doStop()
```
    クラスからコピーされた説明: MessageProducerSupport
    デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
    オーバーライド:
    クラス MessageProducerSupport の doStop
  - pause
```
public void pause()
```
    インターフェースからコピーされた説明: Pausable
    エンドポイントを一時停止します。
    次で指定:
    インターフェース Pausable の pause
  - resume
```
public void resume()
```
    インターフェースからコピーされた説明: Pausable
    一時停止した場合は、エンドポイントを再開します。
    次で指定:
    インターフェース Pausable の resume
  - isPaused
```
public boolean isPaused()
```
    インターフェースからコピーされた説明: Pausable
    エンドポイントが一時停止しているかどうかを確認します。
    次で指定:
    インターフェース Pausable の isPaused
    戻り値:
    一時停止した場合は true。
  - beforeShutdown
```
public int beforeShutdown()
```
    インターフェースからコピーされた説明: OrderlyShutdownCapable
    シャットダウンが始まる前に呼び出されます。実装は、新しいメッセージの受け入れを停止する必要があります。オプションで、処理中のアクティブなメッセージの数を返すことができます。
    次で指定:
    インターフェース OrderlyShutdownCapable の beforeShutdown
    戻り値:
    使用可能な場合、アクティブなメッセージの数。
  - afterShutdown
```
public int afterShutdown()
```
    インターフェースからコピーされた説明: OrderlyShutdownCapable
    スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。
    次で指定:
    インターフェース OrderlyShutdownCapable の afterShutdown
    戻り値:
    使用可能な場合、アクティブなメッセージの数。
  - getErrorMessageAttributes
```
protected AttributeAccessor getErrorMessageAttributes(Message<?> message)
```
    クラスからコピーされた説明: MessageProducerSupport
    errorMessageStrategy でエラーメッセージを作成するときに使用する AttributeAccessor を設定します。
    オーバーライド:
    クラス MessageProducerSupport の getErrorMessageAttributes
    パラメーター:
    message - メッセージ。
    戻り値:
    属性。

クラス KafkaMessageDrivenChannelAdapter<K,V>

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

フィールドのサマリー

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

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

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

コンストラクターの概要

メソッドのサマリー

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

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

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

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

インターフェース org.springframework.integration.support.management.ManageableLifecycle から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

KafkaMessageDrivenChannelAdapter

KafkaMessageDrivenChannelAdapter

メソッドの詳細

setMessageConverter

setRecordMessageConverter

setBatchMessageConverter

setRecordFilterStrategy

setAckDiscarded

setRetryTemplate

setRecoveryCallback

setFilterInRetry

setPayloadType

setOnPartitionsAssignedSeekCallback

setBindSourceRecord

getComponentType

onInit

doStart

doStop

pause

resume

isPaused

beforeShutdown

afterShutdown

getErrorMessageAttributes