我正在尝试使用这里提供的确切代码从 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
,所以我不知道它们应该是什么。
1条答案
按热度按时间64jmpszr1#
eh允许会话超时在6000 ms到300000 ms之间。如果请求的重新平衡超时小于会话超时,我们也会拒绝您的加入组请求。
简要说明-我们实际上并没有运行真正的kafka代理,因此暴露代理配置会增加一些复杂性。但是,我们将用配置值/范围更新github存储库!
11/22/19编辑-配置文件可在此处找到https://github.com/azure/azure-event-hubs-for-kafka/blob/master/configuration.md