public class ApiSensors
extends java.lang.Object
Constructor and Description |
---|
ApiSensors(org.apache.kafka.common.metrics.Sensor requestRate,
org.apache.kafka.common.metrics.Sensor requestByteRate,
org.apache.kafka.common.metrics.Sensor responseByteRate,
org.apache.kafka.common.metrics.Sensor responseTime) |
Modifier and Type | Method and Description |
---|---|
void |
recordErrors(java.util.Map<org.apache.kafka.common.protocol.Errors,java.lang.Integer> errorCounts,
long currentTimeMs) |
void |
recordRequest(long requestSize,
long currentTimeMs) |
void |
recordResponse(long responseSize,
long responseTimeNanos,
long currentTimeMs) |
public ApiSensors(org.apache.kafka.common.metrics.Sensor requestRate, org.apache.kafka.common.metrics.Sensor requestByteRate, org.apache.kafka.common.metrics.Sensor responseByteRate, org.apache.kafka.common.metrics.Sensor responseTime)
public void recordRequest(long requestSize, long currentTimeMs)
public void recordResponse(long responseSize, long responseTimeNanos, long currentTimeMs)
public void recordErrors(java.util.Map<org.apache.kafka.common.protocol.Errors,java.lang.Integer> errorCounts, long currentTimeMs)