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	flushBufferedMetrics()
void	updateBacklogBytes(java.lang.String topic, int partitionId, long backlog)
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 backlog)

Specified by:

updateBacklogBytes in interface KafkaMetrics

flushBufferedMetrics

public void flushBufferedMetrics()

Specified by:

flushBufferedMetrics in interface KafkaMetrics