public class FenceEventInfo extends Object
Modifier and Type | Field and Description |
---|---|
Boolean |
freezeMergedLogStartOffset |
int |
partition |
String |
recordMessageIdBase64 |
long |
recordOffset |
int |
recordPartition |
long |
recordTimestamp |
String |
topic |
String |
topicIdBase64 |
Constructor and Description |
---|
FenceEventInfo(String topic,
String topicIdBase64,
int partition,
String recordMessageIdBase64,
Boolean freezeMergedLogStartOffset,
long recordOffset,
int recordPartition,
long recordTimestamp) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
Boolean |
freezeMergedLogStartOffset() |
int |
hashCode() |
static List<FenceEventInfo> |
jsonToList(Path inputJsonFile) |
static String |
listToJson(List<FenceEventInfo> events) |
int |
partition() |
static List<FenceEventInfo> |
readJsonFromFile(Path jsonFile) |
String |
recordMessageIdBase64() |
long |
recordOffset() |
int |
recordPartition() |
long |
recordTimestamp() |
String |
toJson() |
String |
topic() |
String |
topicIdBase64() |
String |
toString() |
public final String topic
public final String topicIdBase64
public final int partition
public final String recordMessageIdBase64
public final Boolean freezeMergedLogStartOffset
public final long recordOffset
public final int recordPartition
public final long recordTimestamp
public String topic()
public String topicIdBase64()
public int partition()
public String recordMessageIdBase64()
public Boolean freezeMergedLogStartOffset()
public long recordOffset()
public int recordPartition()
public long recordTimestamp()
public String toJson()
public static String listToJson(List<FenceEventInfo> events)
public static List<FenceEventInfo> readJsonFromFile(Path jsonFile) throws IOException
IOException
public static List<FenceEventInfo> jsonToList(Path inputJsonFile) throws IOException
IOException