Low level consumer, producer, and admin client

Metrics

If consumer or producer created by IKafkaFactory with statistics.interval.ms configuration > 0, then following meters are available.

Common tags used by all statistics meters:

• Name - The configured (or default) client.id
• Handler - Handle instance name
• Type - Instance type (producer or consumer)

Epam.Kafka.Statistics

Instruments:

• epam_kafka_stats_trx_msgs- Number of messages consumed or produced.
• epam_kafka_stats_trx - Number of requests transmitted or received.
• epam_kafka_stats_age - Time since this client instance was created (seconds).
• epam_kafka_stats_lag - Sum of known lags for desired topic partitions.

Epam.Kafka.Statistics.Eos

Instruments:

• epam_kafka_stats_eos_txn_state- Transaction state (https://github.com/epam/epam-kafka/blob/main/src/Epam.Kafka/Stats/Eos/TransactionalProducerState.cs).
• epam_kafka_stats_eos_idemp_state - Idempotent state (https://github.com/epam/epam-kafka/blob/main/src/Epam.Kafka/Stats/Eos/IdempotentProducerIdState.cs).

Epam.Kafka.Statistics.ConsumerGroup

Instruments:

• epam_kafka_stats_cg_state - Consumer group handler state (https://github.com/epam/epam-kafka/blob/main/src/Epam.Kafka/Stats/Group/GroupState.cs).
• epam_kafka_stats_cg_join_state - Consumer group handler join state (https://github.com/epam/epam-kafka/blob/main/src/Epam.Kafka/Stats/Group/GroupJoinState.cs).
• epam_kafka_stats_cg_rebalance_age - Time elapsed since last rebalance seconds (seconds).
• epam_kafka_stats_cg_rebalance_count - Total number of rebalances.
• epam_kafka_stats_cg_assignment_count - Current assignment's partition count.

Epam.Kafka.Statistics.TopicPartition

Additional tags:

• Group - Consumer 'group.id'.
• Desired - Is partition explicitly desired by application
• Topic - Topic name
• Partition - Partition value

Instruments:

• epam_kafka_stats_tp_fetch_state - Consumer fetch state (https://github.com/epam/epam-kafka/blob/main/src/Epam.Kafka/Stats/Topic/PartitionFetchState.cs).
• epam_kafka_stats_tp_lag - Consumer lag.