クラスの使用
org.springframework.integration.kafka.dsl.KafkaInboundChannelAdapterSpec
KafkaInboundChannelAdapterSpec を使用するパッケージ
パッケージ
説明
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
org.springframework.integration.kafka.dsl 内の KafkaInboundChannelAdapterSpec 使用
修飾子と型メソッド説明static <K,V> KafkaInboundChannelAdapterSpec <K, V> Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties) コンシューマーファクトリとトピックを使用して初期KafkaInboundChannelAdapterSpecを作成します。static <K,V> KafkaInboundChannelAdapterSpec <K, V> Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, boolean allowMultiFetch) コンシューマーファクトリとトピックを使用して初期KafkaInboundChannelAdapterSpecを作成します。static <K,V> KafkaInboundChannelAdapterSpec <K, V> Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K, V> ackCallbackFactory) コンシューマーファクトリを使用して初期KafkaInboundChannelAdapterSpecを作成し、カスタム ack コールバックファクトリを使用してトピックを作成します。static <K,V> KafkaInboundChannelAdapterSpec <K, V> Kafka.inboundChannelAdapter(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K, V> ackCallbackFactory, boolean allowMultiFetch) コンシューマーファクトリを使用して初期KafkaInboundChannelAdapterSpecを作成し、カスタム ack コールバックファクトリを使用してトピックを作成します。KafkaInboundChannelAdapterSpec.messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) デフォルトを置き換えるようにメッセージコンバーターを設定します。KafkaInboundChannelAdapterSpec.payloadType(ClassSE<?> type) ペイロード型を設定します。KafkaInboundChannelAdapterSpec.rawMessageHeader(boolean rawMessageHeader) true に設定すると、生のConsumerRecordがキーKafkaHeaders.RAW_DATAおよびIntegrationMessageHeaderAccessor.SOURCE_DATAのヘッダーとして含まれます。