Interface KafkaOperations.ProducerCallback<K,​V,​T>

  • Type Parameters:
    K - the key type.
    V - the value type.
    T - the return type.
    Enclosing interface:
    KafkaOperations<K,​V>

    public static interface KafkaOperations.ProducerCallback<K,​V,​T>
    A callback for executing arbitrary operations on the Producer.
    Since:
    1.3
    • Method Detail

      • doInKafka

        T doInKafka​(org.apache.kafka.clients.producer.Producer<K,​V> producer)