@Internal public class PollingRecordPublisherMetricsReporter extends Object
PollingRecordPublisher
s to report metric values.Constructor and Description |
---|
PollingRecordPublisherMetricsReporter(MetricGroup metricGroup) |
Modifier and Type | Method and Description |
---|---|
double |
getBytesPerRead() |
double |
getLoopFrequencyHz() |
int |
getMaxNumberOfRecordsPerFetch() |
long |
getRunLoopTimeNanos() |
long |
getSleepTimeMillis() |
void |
setBytesPerRead(double bytesPerRead) |
void |
setLoopFrequencyHz(double loopFrequencyHz) |
void |
setMaxNumberOfRecordsPerFetch(int maxNumberOfRecordsPerFetch) |
void |
setRunLoopTimeNanos(long runLoopTimeNanos) |
void |
setSleepTimeMillis(long sleepTimeMillis) |
public PollingRecordPublisherMetricsReporter(MetricGroup metricGroup)
public double getLoopFrequencyHz()
public void setLoopFrequencyHz(double loopFrequencyHz)
public double getBytesPerRead()
public void setBytesPerRead(double bytesPerRead)
public long getRunLoopTimeNanos()
public void setRunLoopTimeNanos(long runLoopTimeNanos)
public long getSleepTimeMillis()
public void setSleepTimeMillis(long sleepTimeMillis)
public int getMaxNumberOfRecordsPerFetch()
public void setMaxNumberOfRecordsPerFetch(int maxNumberOfRecordsPerFetch)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.