Spring Cloud Stream Kafka的Azure事件中心连接问题
2019-02-21 22:11:04.681 WARN 1 --- [ad | producer-2]
o.a.k.clients.producer.internals.Sender : [Producer clientId=producer-2]
Got error produce response with correlation id 6 on topic-partition _topic-name_-1,
retrying (4 attempts left). Error: NETWORK_EXCEPTION
org.apache.kafka.common.errors.TimeoutException:
Expiring 1 record(s) for _topic-name_-1:
30096 ms has passed since batch creation plus linger time
2019-02-22 03:03:59.733 INFO 1 --- [container-0-C-1]
o.a.k.c.c.internals.AbstractCoordinator :
[Consumer clientId=consumer-6, groupId=my-super-service]
Group coordinator my-super-hub.servicebus.windows.net:9093
(id: 2147483647 rack: null) is unavailable or invalid, will attempt rediscovery
共有1个答案
您将需要设置最大连接空闲时间。
connections.max.idle.ms
祝你好运.
-
我将消息从windows窗体应用程序发送到azure事件中心。在使用数据流分析进行实时操作后，从事件中心获取数据。在该操作之后，我将结果消息发送到事件集线器。现在我想使用移动应用程序（android或windows mobile应用程序）通过azure notification hub向用户显示结果消息。我们可以直接连接azure通知中心和azure事件中心吗？。
-
我已经实现了下面链接中的代码，用于从事件中心接收事件。但是假设有10个事件，每5个事件检查一次。现在程序在读取第7个事件时异常退出，如果我再次重启事件处理器主机，那么事件(1，2，3，4，6)将被重新读取。请建议我如何再次避免重读和阅读第7次事件？任何例子都值得欣赏。谢了。 https://github.com/Azure/azure-event-hubs/blob/master/samples/
-
关于在物联网场景中使用EventHub的Azure功能，我有几个问题。 EventHub有分区。通常来自特定设备的消息会发送到同一个分区。Azure Function的实例如何分布在EventHub分区中？它是基于性能的吗？如果Azure Function的一个实例设法处理来自所有分区的事件，那么这就足够了，否则每个EventHub分区可能会有一个Azure Function的实例？ 读取偏移量呢
-
我正在尝试使用此处提供的确切代码从启用了的发送/接收数据。 https://github.com/Azure/azure-event-hubs-for-kafka/tree/master/quickstart/dotnet/EventHubsForKafkaSample 我成功地将消息发送到事件中心，但每次尝试初始化接收器时，都会出现此无效会话超时错误。 我唯一指定的超时是，我也尝试过没有它，但错
-
我想将发送到Azure服务总线主题的事件发送到事件中心。这可能吗？ 详细信息：我与我公司的另一个团队合作，该团队接收Azure Service Bus主题的第三方事件（通过webhook），并在不同的应用程序中进一步使用。 我的团队现在希望使用我们现有的事件中心并使用Azure捕获将这些事件存储到存储帐户来收听/订阅此主题。 我做了以下工作： 我在他们的Azure服务总线中创建了他们主题的订阅。我
-
我们计划在Azure云上使用Spring云数据流，使用Azure EventHub作为消息绑定器。在Azure EventHub上，存在硬限制： 100个名称空间 每个名称空间10个主题 SpringCloudAzure事件中心流绑定器似乎只能配置一个名称空间，那么我们如何管理多个名称空间呢？ 也许我们应该使用多个绑定器，以拥有SpringCloudAzure事件中心流绑定器的多个实例？ 有人有什