ClusterConfigurationBuilderExtensions.EnableTelemetry method (1 of 2)

public static IClusterConfigurationBuilder EnableTelemetry(
    this IClusterConfigurationBuilder cluster, string topicName)

See Also

• class ClusterConfigurationBuilderExtensions
• namespace KafkaFlow

---

ClusterConfigurationBuilderExtensions.EnableTelemetry method (2 of 2)

Creates the telemetry producer and consumer to send and receive metric messages

public static IClusterConfigurationBuilder EnableTelemetry(
    this IClusterConfigurationBuilder cluster, string topicName, string consumerGroup, 
    TimeSpan? cleanRunInterval = default, TimeSpan? expiryTime = default, int topicPartition = 0)

parameter	description
cluster	The cluster configuration builder
topicName	The topic to be used by the metric commands
consumerGroup	The consumer group prefix
cleanRunInterval	How often run storage cleanup. Every 10 minutes by default
expiryTime	Cleanup will remove metrics older than specified interval. 6 hours by default
topicPartition	The partition used to produce and consumer telemetry data

See Also

• class ClusterConfigurationBuilderExtensions
• namespace KafkaFlow