启用Kafka的Azure事件中心：接收器中的会话超时无效
我正在尝试使用此处提供的确切代码从启用了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个答案
EH允许6000毫秒到300000毫秒之间的会话超时。如果请求的重新平衡超时小于会话超时，我们也会拒绝您的加入组请求。
快速注意-我们实际上并没有运行真正的Kafka代理，因此公开代理配置会增加一点复杂性。但是，我们将使用配置值/范围更新我们的Github存储库！
11/22/19编辑-配置文档可以在这里找到https://github.com/Azure/azure-event-hubs-for-kafka/blob/master/CONFIGURATION.md
-
我需要一起处理相同的消息集，为此，我尝试了Azure服务总线会话启用功能。为了测试这一点，我创建了一个非常简单的应用程序，一个消息在队列中成功提交，然而，当试图在“ReceiveSessionMessage”函数中接收消息时，消息会话不会返回，程序会在这一行之后退出。 我无法找出确切的根本原因，任何帮助都将不胜感激。谢谢 等待会话客户端。AcceptMessageSessionAsync（）；]
-
我正在使用版本来使用来自主题的消息。在使用者配置中，自动提交设置为，而设置为。与服务器协商为10秒。 在收到消息后，我将它的一部分保存到数据库中。我的数据库有时会非常慢,这会导致kafka侦听器会话超时： 组MyGroup得自动偏移量提交失败：无法完成提交,因为组已重新平衡并将分区分配给另一个成员.这意味着对poll（）的后续调用之间的时间比配置的session.timeout.ms长，这通常意味
-
Chrome93最近发布。大约在这个时候（8月31日下午4点），我们的端到端测试开始失败。这些测试利用量角器，通过TeamCity在安装了Chrome93的Windows构建代理上运行。 我们试图强制一个93. x和一个92. x版本的chrome驱动程序。两者都会在下面产生这个超时。我们可以在本地运行这些e2e测试，没有问题。有什么建议吗？
-
关于在物联网场景中使用EventHub的Azure功能，我有几个问题。 EventHub有分区。通常来自特定设备的消息会发送到同一个分区。Azure Function的实例如何分布在EventHub分区中？它是基于性能的吗？如果Azure Function的一个实例设法处理来自所有分区的事件，那么这就足够了，否则每个EventHub分区可能会有一个Azure Function的实例？ 读取偏移量呢
-
我已经实现了下面链接中的代码，用于从事件中心接收事件。但是假设有10个事件，每5个事件检查一次。现在程序在读取第7个事件时异常退出，如果我再次重启事件处理器主机，那么事件(1，2，3，4，6)将被重新读取。请建议我如何再次避免重读和阅读第7次事件？任何例子都值得欣赏。谢了。 https://github.com/Azure/azure-event-hubs/blob/master/samples/