Package org.apache.beam.sdk.io.kafka

Interface KafkaMetrics

All Known Implementing Classes:

KafkaMetrics.KafkaMetricsImpl, KafkaMetrics.NoOpKafkaMetrics

public interface KafkaMetrics

Stores and exports metrics for a batch of Kafka Client RPCs.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	KafkaMetrics.KafkaMetricsImpl	Metrics of a batch of RPCs.
static class	KafkaMetrics.NoOpKafkaMetrics	No-op implementation of KafkaResults.

Method Summary

Modifier and Type	Method	Description
void	flushBufferedMetrics()
void	updateBacklogBytes(String topic, int partitionId, long backlog)
void	updateSuccessfulRpcMetrics(String topic, Duration elapsedTime)

Method Details

updateSuccessfulRpcMetrics

void updateSuccessfulRpcMetrics(String topic,
 Duration elapsedTime)

updateBacklogBytes

void updateBacklogBytes(String topic,
 int partitionId,
 long backlog)

flushBufferedMetrics

void flushBufferedMetrics()