消费者(Java客户端)选择代理0作为组协调器，并开始正确地使用消息。但是，当作为组协调器的代理0关闭时，消费者不做任何事情，并停止使用poll()方法。仅当代理0启动并运行时，该进程才会恢复。如何处理Java客户端中组协调器更改的这种场景？当组协调器死亡时，我得到这个错误：
16/09/22 17:42:45 INFO in
浏览 34提问于2016-09-23得票数 10
最近，我们经常在Java中遇到“来自SyncGroup的错误:请求超时”。
这一问题通常发生在卡夫卡集群中很少的话题或消费者群体中。有人能提供一些关于这个错误的提示吗？at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$SyncGroupRequestHandler.handle(AbstractCoordinator.java(AbstractCoordinat
浏览 5提问于2016-09-21得票数 5
1回答
我正在测试火花结构化流使用kafka.i有一个kafka-broker(0.10.1) on host28，默认分区num:num.partitions=1bin/kafka-console-producer.sh--broker-list host28:6667 --topic testbin/kafka-console-consumer.sh --zookeeper host26:2181,host27:2181,host28:2181
浏览 1提问于2018-08-17得票数 0
在我的kafka streams应用程序中创建状态存储时，我得到了这个错误Failed to lock the state directory: /tmp/kafka-streams/string-monitor:222)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$1.onSuccess(AbstractCoordinator.jav
浏览 19提问于2016-08-30得票数 4
(NetworkClient.java:435)at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.clientPoll(ConsumerNetworkClient.java:320)
at org.apache.kafka.clients.<
浏览 4提问于2017-06-07得票数 3
在我们迁移到IBM Cloud上的新标准计划事件流之前，它可以很好地工作。然后我们在下面遇到了异常。它说我们的主题retentions.ms不适合范围3600000..2592000000。:419) at org.apache.
浏览 0提问于2019-12-18得票数 0
我们正在将kafka实现升级到.9，并使用新的使用者java来创建使用者。我正在为消费者使用下面的代码，我们使用对消费者设置主题，如A行和B行是对我们的服务的调用，它处理我们接收到的消息。:标记协调器2147483647死亡。(AbstractCoordinator.java:665) at org.apache.kafka.clients.consumer.internals.<
浏览 1提问于2016-03-09得票数 6
回答已采纳
运行在Confluent Cloud上的kafka streams版本2.1.0在kafka streams应用启动时出现以下错误： java.util.concurrent.ExecutionException:403)
at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader(AbstractCoordinator.java:56
浏览 10提问于2019-02-03得票数 1
| otm-opl-group] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId| otm-opl-group] INFO org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId(id: 2147483644
浏览 4提问于2020-03-30得票数 4
1回答
(AbstractCoordinator.java:515) at org.apache.kafka.clients.consumer.inte
浏览 13提问于2019-04-12得票数 1
回答已采纳
下面是引发错误的日志的一部分：at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.access$1100
浏览 0提问于2019-07-15得票数 4
最近，我们的(Kafka 1.1.1)经纪人倒闭了，我们的Kafka流应用程序也停止了工作。因此，我们手动停止应用程序以停止警报。卡夫卡再次上线后，我们启动了流应用程序，但它没有读取来自主题的任何消息。在阅读了日志之后，我们发现了组协调员不断发现的日志，然后在一个无穷无尽的循环中再次变得不可用。loggerName":"org.apache.kafka.cli
浏览 0提问于2020-05-13得票数 1
我几乎复制了其中的大部分(除了PageViewEventSource)，并将名称重构到我的用例中。我还用示例中使用的键更新了我的application.properties。(AbstractCoordinator.java:622) ~[kafka-clients-2.3.1.jar:na]
at org.apache.kafka.clients.consumer.internals.AbstractCoordina
浏览 3提问于2020-02-12得票数 3
回答已采纳
Java: OpenJdk 11 Kafka: 2.2.0Kafka流库: 2.3.0
我正在尝试将我的Kafka应用程序部署到停靠器容器中，但是它在尝试使用TopicAuthorizationException本地和服务器之间的主要区别是，它连接到部署了Kafka的服务器，并使用通常的Kerberos auth进行身份验证。我无法理解身份验证与本地存储之间的联系
浏览 2提问于2019-10-09得票数 8
回答已采纳
我刚刚将我们的Kafka Stream应用程序从2.5.1升级到2.6.2。它以前是有效的，但现在不行了。(AbstractCoordinator.java:684) at org.ap
浏览 52提问于2021-05-15得票数 3
在org.apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader(AbstractCoordinator.java在org.apache.kafka.clients.consumer.internals.AbstractCoordinator.access$1000(AbstractCoordinator.java在org.ap
浏览 14提问于2022-11-28得票数 0
我似乎不能让我的Java Kafka客户端工作。症状： “发现的协调器”出现在日志中，然后不到一秒后，“正在标记协调器...已死”。在此之后不再显示输出。- Kafka commitId : 26ddb9e3197be39a
2019-09-25 15:25:47.700 [pool-2-thread-1] INFO org.apache.kafka.clients.
浏览 37提问于2019-09-25得票数 0
回答已采纳
#0-1-C-1 ERROR o.a.k.c.c.i.ConsumerCoordinator -用户为组文档提供侦听器com.linkedin.kafka.clients.consumer.LiKafkaConsumerRebalanceListener(ConsumerCoordinator.java:255) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfN
浏览 2提问于2017-07-03得票数 0
我试着用卡夫卡-客户库(0.9.0.1)来测试生产者，消费者.代理(0.9.0.1)正在服务器上运行，我已经进行了测试KafkaProducer，没有问题。，但是当我检查Kafka核心源时，我重新定义了请求类型键'10‘定义为’Group协调员键‘。(ConsumerNetworkClient.java:163) at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureC
浏览 0提问于2016-03-18得票数 1
6回答
我正在尝试通过使用远程kafka集群上的主题数据来检查Kafka消费者。(ConsumerNetworkClient.java:548) at o
浏览 180提问于2019-01-30得票数 18
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
