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	updateKafkaMetrics()
void	updateSuccessfulRpcMetrics(java.lang.String topic, java.time.Duration elapsedTime)

Method Detail

updateSuccessfulRpcMetrics

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

updateKafkaMetrics

void updateKafkaMetrics()