org.apache.beam.sdk.io.kafka

Class KafkaMetrics.NoOpKafkaMetrics

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaMetrics.NoOpKafkaMetrics

All Implemented Interfaces:

KafkaMetrics

Enclosing interface:

KafkaMetrics

public static class KafkaMetrics.NoOpKafkaMetrics
extends java.lang.Object
implements KafkaMetrics

No-op implementation of KafkaResults.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.kafka.KafkaMetrics

KafkaMetrics.KafkaMetricsImpl, KafkaMetrics.NoOpKafkaMetrics

Method Summary

Modifier and Type	Method and Description
void	updateBacklogBytes(java.lang.String topic, int partitionId, long elapsedTime)
void	updateKafkaMetrics()
void	updateSuccessfulRpcMetrics(java.lang.String topic, java.time.Duration elapsedTime)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

updateSuccessfulRpcMetrics

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

Specified by:

updateSuccessfulRpcMetrics in interface KafkaMetrics

updateBacklogBytes

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

Specified by:

updateBacklogBytes in interface KafkaMetrics

updateKafkaMetrics

public void updateKafkaMetrics()

Specified by:

updateKafkaMetrics in interface KafkaMetrics