public static class KafkaSupervisorReport.KafkaSupervisorReportPayload extends Object
Constructor and Description |
---|
KafkaSupervisorReportPayload(String dataSource,
String topic,
Integer partitions,
Integer replicas,
Long durationSeconds,
Map<Integer,Long> latestOffsets,
Map<Integer,Long> minimumLag,
Long aggregateLag,
org.joda.time.DateTime offsetsLastUpdated) |
Modifier and Type | Method and Description |
---|---|
List<TaskReportData> |
getActiveTasks() |
Long |
getAggregateLag() |
String |
getDataSource() |
Long |
getDurationSeconds() |
Map<Integer,Long> |
getLatestOffsets() |
Map<Integer,Long> |
getMinimumLag() |
org.joda.time.DateTime |
getOffsetsLastUpdated() |
Integer |
getPartitions() |
List<TaskReportData> |
getPublishingTasks() |
Integer |
getReplicas() |
String |
getTopic() |
String |
toString() |
public KafkaSupervisorReportPayload(String dataSource, String topic, Integer partitions, Integer replicas, Long durationSeconds, @Nullable Map<Integer,Long> latestOffsets, @Nullable Map<Integer,Long> minimumLag, @Nullable Long aggregateLag, @Nullable org.joda.time.DateTime offsetsLastUpdated)
public String getDataSource()
public String getTopic()
public Integer getPartitions()
public Integer getReplicas()
public Long getDurationSeconds()
public List<TaskReportData> getActiveTasks()
public List<TaskReportData> getPublishingTasks()
public Long getAggregateLag()
public org.joda.time.DateTime getOffsetsLastUpdated()
Copyright © 2011–2018. All rights reserved.