Я пытаюсь использовать точный код, предоставленный здесь, для отправки / получения данных с Kafka включенным Azure Event Hub.
https://github.com/Azure/azure-event-hubs-for-kafka/tree/master/quickstart/dotnet/EventHubsForKafkaSample
Я успешно отправляю сообщения в концентратор событий, но каждый раз, когда я пытаюсь инициализировать получателя, я получаю эту недопустимую ошибку тайм-аута сеанса.
7|2018-11-14 19:10:52.967|ssarkar#consumer-1|SEND| [thrd:sasl_ssl://ssarkar-test.servicebus.windows.net:9093/bootstrap]: sasl_ssl://ssarkar-test.servicebus.windows.net:9093/0: Sent JoinGroupRequest (v0, 109 bytes @ 0, CorrId 6)
7|2018-11-14 19:10:52.992|ssarkar#consumer-1|RECV| [thrd:sasl_ssl://ssarkar-test.servicebus.windows.net:9093/bootstrap]: sasl_ssl://ssarkar-test.servicebus.windows.net:9093/0: Received JoinGroupResponse (v0, 16 bytes, CorrId 6, rtt 24.28ms)
7|2018-11-14 19:10:52.992|ssarkar#consumer-1|REQERR| [thrd:main]: sasl_ssl://ssarkar-test.servicebus.windows.net:9093/0: JoinGroupRequest failed: Broker: Invalid session timeout: actions Permanent
Единственный тайм-аут, который я указываю, это request.timeout.ms, и я тоже пробовал без этого, но ошибка не исчезнет. Я также пытался использовать различные значения session.timeout.ms, но ошибка сохраняется.
В Интернете есть некоторая информация о том, что значение времени ожидания сеанса находится в пределах минимального и максимального значений времени ожидания группы. Но у меня нет способа просмотреть конфиги брокера на Azure Event Hub, поэтому я понятия не имею, какими они должны быть.