已启用Kafka的Azure事件中心：接收器中的无效会话超时

Question

我正在尝试使用此处提供的确切代码从启用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上的代理配置，所以我不知道它们应该是什么。

Answer 1

EH允许会话超时在6000毫秒和300000毫秒之间。如果请求的重新平衡超时小于会话超时，我们也会拒绝您的加入组请求。

快速说明-我们实际上不是在运行真正的Kafka经纪人，因此公开经纪人配置会增加一些复杂性。但是，我们将使用配置值/范围更新我们的Github存储库！