Constructor and Description |
---|
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K, V>)
in favor of
#KafkaAckCallback(KafkaAckInfo, ConsumerProperties) |
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallback(KafkaMessageSource.KafkaAckInfo<K, V>, Duration)
in favor of
#KafkaAckCallback(KafkaAckInfo, ConsumerProperties) |
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory()
in favor of
#KafkaAckCallbackFactory(ConsumerProperties) . |
org.springframework.integration.kafka.inbound.KafkaMessageSource(ConsumerFactory<K, V>, KafkaMessageSource.KafkaAckCallbackFactory<K, V>, String...) |
org.springframework.integration.kafka.inbound.KafkaMessageSource(ConsumerFactory<K, V>, String...) |