パッケージ org.springframework.integration.kafka.dsl

クラス KafkaInboundChannelAdapterSpec<K,V>

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec<S,H>
org.springframework.integration.dsl.MessageSourceSpec < KafkaInboundChannelAdapterSpec <K, V>、KafkaMessageSource <K, V>>
org.springframework.integration.kafka.dsl.KafkaInboundChannelAdapterSpec<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<KafkaMessageSource<K,V>>、InitializingBean、Lifecycle、Phased、SmartLifecycle
public class KafkaInboundChannelAdapterSpec<K,V> extends MessageSourceSpec<KafkaInboundChannelAdapterSpec<K,V>,KafkaMessageSource<K,V>>
ポーリングされた Apache Kafka 受信チャネルアダプターの仕様。
導入:
5.4
作成者:
Gary Russell, Anshul Mehra, Artem Bilan

  • メソッドの詳細

    • messageConverter

      public KafkaInboundChannelAdapterSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
      デフォルトを置き換えるようにメッセージコンバーターを設定します。MessagingMessageConverter。
      パラメーター:
      messageConverter - コンバーター。
      戻り値:
      スペック。

    • payloadType

      public KafkaInboundChannelAdapterSpec<K,V> payloadType(ClassSE<?> type)
      ペイロード型を設定します。型対応のメッセージコンバーターが提供されている場合にのみ適用されます。
      パラメーター:
      type - 変換する型。
      戻り値:
      スペック。

    • rawMessageHeader

      public KafkaInboundChannelAdapterSpec<K,V> rawMessageHeader(boolean rawMessageHeader)
      true に設定すると、生の ConsumerRecord がキー KafkaHeaders.RAW_DATA および IntegrationMessageHeaderAccessor.SOURCE_DATA のヘッダーとして含まれます。発信者がレコードにアクセスしてエラーを処理できるようにします。
      パラメーター:
      rawMessageHeader - ヘッダーを含める場合は true。
      戻り値:
      スペック。