Table of Contents

Class KafkaStatistics

Namespace
Silverback.Messaging.Broker.Callbacks.Statistics
Assembly
Silverback.Integration.Kafka.dll

A Kafka statistics event. See https://github.com/edenhill/librdkafka/blob/master/STATISTICS.md for information about the structure.

public class KafkaStatistics
Inheritance
KafkaStatistics
Inherited Members

Constructors

KafkaStatistics()

public KafkaStatistics()

Properties

Brokers

[JsonPropertyName("brokers")]
public Dictionary<string, BrokerStatistics> Brokers { get; init; }

Property Value

Dictionary<string, BrokerStatistics>

ClientId

[JsonPropertyName("client_id")]
public string ClientId { get; init; }

Property Value

string

ConsumerGroup

[JsonPropertyName("cgrp")]
public ConsumerGroupStatistics ConsumerGroup { get; init; }

Property Value

ConsumerGroupStatistics

ExactlyOnceSemantics

[JsonPropertyName("eos")]
public ExactlyOnceSemanticsStatistics ExactlyOnceSemantics { get; init; }

Property Value

ExactlyOnceSemanticsStatistics

MetadataCacheCnt

[JsonPropertyName("metadata_cache_cnt")]
public long MetadataCacheCnt { get; init; }

Property Value

long

MsgCnt

[JsonPropertyName("msg_cnt")]
public long MsgCnt { get; init; }

Property Value

long

MsgMax

[JsonPropertyName("msg_max")]
public long MsgMax { get; init; }

Property Value

long

MsgSize

[JsonPropertyName("msg_size")]
public long MsgSize { get; init; }

Property Value

long

MsgSizeMax

[JsonPropertyName("msg_size_max")]
public long MsgSizeMax { get; init; }

Property Value

long

Name

[JsonPropertyName("name")]
public string Name { get; init; }

Property Value

string

ReplyQ

[JsonPropertyName("replyq")]
public long ReplyQ { get; init; }

Property Value

long

Rx

[JsonPropertyName("rx")]
public long Rx { get; init; }

Property Value

long

RxBytes

[JsonPropertyName("rx_bytes")]
public long RxBytes { get; init; }

Property Value

long

RxMsgBytes

[JsonPropertyName("rxmsg_bytes")]
public long RxMsgBytes { get; init; }

Property Value

long

RxMsgs

[JsonPropertyName("rxmsgs")]
public long RxMsgs { get; init; }

Property Value

long

SimpleCnt

[JsonPropertyName("simple_cnt")]
public long SimpleCnt { get; init; }

Property Value

long

Time

[JsonPropertyName("time")]
public long Time { get; init; }

Property Value

long

Topics

[JsonPropertyName("topics")]
public Dictionary<string, TopicStatistics> Topics { get; init; }

Property Value

Dictionary<string, TopicStatistics>

Ts

[JsonPropertyName("ts")]
public long Ts { get; init; }

Property Value

long

Tx

[JsonPropertyName("tx")]
public long Tx { get; init; }

Property Value

long

TxBytes

[JsonPropertyName("tx_bytes")]
public long TxBytes { get; init; }

Property Value

long

TxMsgBytes

[JsonPropertyName("txmsg_bytes")]
public long TxMsgBytes { get; init; }

Property Value

long

TxMsgs

[JsonPropertyName("txmsgs")]
public long TxMsgs { get; init; }

Property Value

long

Type

[JsonPropertyName("type")]
public string Type { get; init; }

Property Value

string