Interface ConsumerFactory<K,V>

All Superinterfaces:
Serializable
All Known Implementing Classes:
ConsumerFactoryDefault

public interface ConsumerFactory<K,V> extends Serializable
This is here to enable testing.
  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.kafka.clients.consumer.Consumer<K,V>
    createConsumer(Map<String,Object> consumerProps)
     
  • Method Details

    • createConsumer

      org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(Map<String,Object> consumerProps)