Interface KafkaConsumerProvider

public interface KafkaConsumerProvider

  • Method Summary

    Modifier and Type
    Method
    Description
    <K,V> org.apache.kafka.clients.consumer.KafkaConsumer<K,V>
    getConsumer(Properties consumerConfigOverride)
     
    <K,V> void
    releaseConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)
     

  • Method Details

    • getConsumer

      <K,V> org.apache.kafka.clients.consumer.KafkaConsumer<K,V> getConsumer(Properties consumerConfigOverride)

    • releaseConsumer

      <K,V> void releaseConsumer(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer)