Interface KafkaMessageMetadata<K>

    • Method Detail

      • getTopic

        String getTopic()
        Get the topic
        Returns:
        the name of the topic
      • getKey

        K getKey()
        Get the key
        Returns:
        the key
      • getTimestamp

        Instant getTimestamp()
        Get the timestamp
        Returns:
        the timestamp
      • getHeaders

        org.apache.kafka.common.header.Headers getHeaders()
        Get the Kafka headers
        Returns:
        the Kafka headers
      • getPartition

        int getPartition()
        Get the partition
        Returns:
        the partition