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 and 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 and Description
void	updateBacklogBytes(java.lang.String topic, int partitionId, long backlog)
void	updateKafkaMetrics()
void	updateSuccessfulRpcMetrics(java.lang.String topic, java.time.Duration elapsedTime)

Method Detail

updateSuccessfulRpcMetrics

void updateSuccessfulRpcMetrics(java.lang.String topic,
                                java.time.Duration elapsedTime)

updateBacklogBytes

void updateBacklogBytes(java.lang.String topic,
                        int partitionId,
                        long backlog)

updateKafkaMetrics

void updateKafkaMetrics()