レコードクラスの使用箇所
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory
KafkaMessageSource.KafkaAckCallbackFactory を使用するパッケージ
パッケージ
説明
Apache Kafka 用の Spring Integration Java DSL コンポーネントサポートを提供します。
Apache Kafka 用の Spring Integration 受信コンポーネントを提供します。
org.springframework.integration.kafka.dsl 内の KafkaMessageSource.KafkaAckCallbackFactory 使用
型 KafkaMessageSource.KafkaAckCallbackFactory のパラメーターを持つ org.springframework.integration.kafka.dsl のメソッド修飾子と型メソッド説明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 コールバックファクトリを使用してトピックを作成します。org.springframework.integration.kafka.inbound 内の KafkaMessageSource.KafkaAckCallbackFactory 使用
型 KafkaMessageSource.KafkaAckCallbackFactory のパラメーターを持つ org.springframework.integration.kafka.inbound のコンストラクター修飾子コンストラクター説明KafkaMessageSource(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K, V> ackCallbackFactory) 指定されたパラメーターを使用してインスタンスを作成します。KafkaMessageSource(org.springframework.kafka.core.ConsumerFactory<K, V> consumerFactory, org.springframework.kafka.listener.ConsumerProperties consumerProperties, KafkaMessageSource.KafkaAckCallbackFactory<K, V> ackCallbackFactory, boolean allowMultiFetch) 指定されたパラメーターを使用してインスタンスを作成します。