Class KafkaMessageSource.KafkaAckCallbackFactory<K,​V>

java.lang.Object
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckCallbackFactory<K,​V>
Type Parameters:
K - the key type.
V - the value type.
All Implemented Interfaces:
org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,​V>>
Enclosing class:
KafkaMessageSource<K,​V>

public static class KafkaMessageSource.KafkaAckCallbackFactory<K,​V>
extends java.lang.Object
implements org.springframework.integration.acks.AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,​V>>
AcknowledgmentCallbackFactory for KafkaAckInfo.
  • Constructor Summary

    Constructors 
    Constructor Description
    KafkaAckCallbackFactory​(org.springframework.kafka.listener.ConsumerProperties consumerProperties)
    Construct an instance with the provided properties.
  • Method Summary

    Modifier and Type Method Description
    org.springframework.integration.acks.AcknowledgmentCallback createCallback​(KafkaMessageSource.KafkaAckInfo<K,​V> info)  

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • KafkaAckCallbackFactory

      public KafkaAckCallbackFactory​(org.springframework.kafka.listener.ConsumerProperties consumerProperties)
      Construct an instance with the provided properties.
      Parameters:
      consumerProperties - the properties.
  • Method Details

    • createCallback

      public org.springframework.integration.acks.AcknowledgmentCallback createCallback​(KafkaMessageSource.KafkaAckInfo<K,​V> info)
      Specified by:
      createCallback in interface org.springframework.integration.acks.AcknowledgmentCallbackFactory<K>