Class UCentralKafkaConsumer.KafkaRecord

  • Enclosing class:
    UCentralKafkaConsumer

    public static class UCentralKafkaConsumer.KafkaRecord
    extends Object
    Representation of Kafka record.
    • Field Detail

      • serialNumber

        public final String serialNumber
        The device serial number.
      • payload

        public final com.google.gson.JsonObject payload
        The state payload JSON.
      • timestampMs

        public final long timestampMs
        The record timestamp (Unix time, in ms). Depending on the broker configuration for "message.timestamp.type", this may either be the "CreateTime" or "LogAppendTime".
    • Constructor Detail

      • KafkaRecord

        public KafkaRecord​(String serialNumber,
                           com.google.gson.JsonObject payload,
                           long timestampMs)
        Constructor.