Interface RecordContext


  • public interface RecordContext
    The context associated with the current record being processed by an Processor
    • Method Detail

      • offset

        long offset()
        Returns:
        The offset of the original record received from Kafka; could be -1 if it is not available
      • timestamp

        long timestamp()
        Returns:
        The timestamp extracted from the record received from Kafka; could be -1 if it is not available
      • topic

        String topic()
        Returns:
        The topic the record was received on; could be null if it is not available
      • partition

        int partition()
        Returns:
        The partition the record was received on; could be -1 if it is not available
      • headers

        Headers headers()
        Returns:
        The headers from the record received from Kafka; could be null if it is not available