Package org.voltdb.stream.api.kafka

Interface KafkaRequest<K,V>

Type Parameters:
K - key type configured by kafka consumer
V - value type configured by kafka consumer
public interface KafkaRequest<K,V>
this interface exposes key, value and headers of kafka message consumed from broker. Note: Do not cache this object as it may be reused depending on the implementation.

  • Method Details

    • getKey

      K getKey()

    • getValue

      V getValue()

    • getHeaders

      Map<String,String> getHeaders()