public class KafkaSupervisorReport extends SupervisorReport
Modifier and Type | Class and Description |
---|---|
static class |
KafkaSupervisorReport.KafkaSupervisorReportPayload |
Constructor and Description |
---|
KafkaSupervisorReport(String dataSource,
org.joda.time.DateTime generationTime,
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 |
---|---|
void |
addTask(TaskReportData data) |
Object |
getPayload() |
String |
toString() |
getGenerationTime, getId
public KafkaSupervisorReport(String dataSource, org.joda.time.DateTime generationTime, 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 Object getPayload()
getPayload
in class SupervisorReport
public void addTask(TaskReportData data)
Copyright © 2011–2018. All rights reserved.