Interface KafkaConsumerRecord<K,​V>


  • public interface KafkaConsumerRecord<K,​V>
    Vert.x Kafka consumer record
    • Method Detail

      • topic

        String topic()
        Returns:
        the topic this record is received from
      • partition

        int partition()
        Returns:
        the partition from which this record is received
      • offset

        long offset()
        Returns:
        the position of this record in the corresponding Kafka partition.
      • timestamp

        long timestamp()
        Returns:
        the timestamp of this record
      • timestampType

        org.apache.kafka.common.record.TimestampType timestampType()
        Returns:
        the timestamp type of this record
      • key

        K key()
        Returns:
        the key (or null if no key is specified)
      • value

        V value()
        Returns:
        the value
      • headers

        List<KafkaHeader> headers()
        Returns:
        the list of consumer record headers
      • record

        org.apache.kafka.clients.consumer.ConsumerRecord<K,​V> record()
        Returns:
        the native Kafka consumer record with backed information