Interface ConsumerPostProcessor<K,​V>

  • Type Parameters:
    K - the key type.
    V - the value type
    All Superinterfaces:
    java.util.function.Function<org.apache.kafka.clients.consumer.Consumer<K,​V>,​org.apache.kafka.clients.consumer.Consumer<K,​V>>

    public interface ConsumerPostProcessor<K,​V>
    extends java.util.function.Function<org.apache.kafka.clients.consumer.Consumer<K,​V>,​org.apache.kafka.clients.consumer.Consumer<K,​V>>
    Called by consumer factories to perform post processing on newly created consumers.
    Since:
    2.5.3
    Author:
    Gary Russell
    • Method Summary

      • Methods inherited from interface java.util.function.Function

        andThen, apply, compose