Kafka 已启用 Azure 事件中心：Receiver 中的会话超时无效答案

【问题标题】：Kafka enabled Azure Event Hub: Invalid session timeout in ReceiverKafka 已启用 Azure 事件中心：Receiver 中的会话超时无效
【发布时间】：2018-11-15 03:14:57
【问题描述】：

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

【问题讨论】：

标签： azure apache-kafka azure-eventhub

【解决方案1】：

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

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

11/22/19 编辑 - 配置文档可以在这里找到https://github.com/Azure/azure-event-hubs-for-kafka/blob/master/CONFIGURATION.md

【讨论】：