org.apache.kafka.common.errors.ApiException: тайм-аут сеанса не находится в допустимом диапазоне

Question

Я получаю выше исключения у своего потребителя с kafka 0.9.0.1. По этой теме [1] я не вижу " group.max.session.timeout.ms "в файле server.properties.

org.apache.kafka.common.errors.ApiException: The session timeout is not within an acceptable range 

Любые подсказки?

[1] http://comments.gmane.org/gmane.comp.apache.kafka.user/12426

Answer 1

Существует на стороне сервера конфигурации в Кафке, что ограничивает максимальное значение времени ожидания:

group.max.session.timeout.ms 

Значение по умолчанию равно 30000ms, если он не установлен.

Это находится в «/config/server.properties».

Установите его на более высокое значение, чем тайм-аут вашего потребителя, и все будет в порядке.