Class UCentralKafkaConsumer.KafkaRecord
- java.lang.Object
-
- com.facebook.openwifi.cloudsdk.kafka.UCentralKafkaConsumer.KafkaRecord
-
- Enclosing class:
- UCentralKafkaConsumer
public static class UCentralKafkaConsumer.KafkaRecord extends Object
Representation of Kafka record.
-
-
Field Summary
Fields Modifier and Type Field Description com.google.gson.JsonObject
payload
The state payload JSON.String
serialNumber
The device serial number.long
timestampMs
The record timestamp (Unix time, in ms).
-
Constructor Summary
Constructors Constructor Description KafkaRecord(String serialNumber, com.google.gson.JsonObject payload, long timestampMs)
Constructor.
-
-
-
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.
-
-