Class WallclockTimestampExtractor

    • Constructor Detail

      • WallclockTimestampExtractor

        public WallclockTimestampExtractor()
    • Method Detail

      • extract

        public long extract​(ConsumerRecord<Object,​Object> record,
                            long partitionTime)
        Return the current wall clock time as timestamp.
        Specified by:
        extract in interface TimestampExtractor
        Parameters:
        record - a data record
        partitionTime - the highest extracted valid timestamp of the current record's partition˙ (could be -1 if unknown)
        Returns:
        the current wall clock time, expressed in milliseconds since midnight, January 1, 1970 UTC