Потребление (тайм-аут) с тайм-аутом> max.poll.interval.ms, не вызывающим перебаланс - PullRequest
Новая
       79

Потребление (тайм-аут) с тайм-аутом> max.poll.interval.ms, не вызывающим перебаланс

1 голос
/ 30 марта 2020

Из моего понимания конфигурации max.poll.interval.ms, если мой потребитель не потребляет () хотя бы один раз за этот интервал, произойдет перебалансировка.

Однако я не могу вызвать этот баланс. Я неправильно понимаю эту конфигурацию? Вот пример моего кода:

Соответствующие потребительские конфигурации: 

BootstrapServers = "localhost:9092",
GroupId = "group1",
SessionTimeoutMs = 10000, 
HeartbeatIntervalMs = 3000, 
MaxPollIntervalMs = 11000

Что я делаю: 

while (!cancellationToken.IsCancellationRequested)
{
   Console.WriteLine($"{DateTime.UtcNow}: Consume()");
   var message = consumer.Consume(new TimeSpan(0, 0, seconds: 30));
}

Это печатает каждые 30 с "Consume () сообщение Не должен ли он вместо этого вызвать ребаланс через 11 секунд из-за max.poll.interval.ms = 11000?

Я использую Confluent.Kafka 1.3.0

...