Incorrect values in statistics callback

[greatvovan]

In the beginning it returns believeable values but each time callback triggers values reduce, and this continues until they get down to zero. At the same time I know that nothing consumes from topics and Kafka system tools show me the real values.

I do it like this:

var config = new Config
{
    GroupId = "mygroup",
    StatisticsInterval = TimeSpan.FromSeconds(10),
};

var consumer = new Consumer(config, "host1:9092,host2:9092,host3:9092");
consumer.Subscribe(new List<string> { "my_topic" });
consumer.OnStatistics += StatisticsHandler;

private static void StatisticsHandler(object sender, string json)
{
    // Extract topics/demo.crawled_firehose/partitions/*/consumer_lag from json
}

My consumers use new_consumer protocol.

[ah-]

This sounds like a librdkafka issue, could you report it at https://github.com/edenhill/librdkafka/issues?

[ah-]

Do you have any detail on what exactly is wrong?

[greatvovan]

What exactly is wrong is returned values themself. It is not normal that it reports values continiously decreasing to zero, isn't it?