kafka消费者命名方法错误:未定义的方法“length”nil:nilclass

jvidinwx  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(253)

我正在运行多个kafka使用者,每个使用者都在自己的服务器上,它们正在读取远程kafka集群上定义的同一主题。50台服务器中只有5台成功运行使用者进程。其余部分无法启动-以下是日志:
i、 [2017-06-20t20:25:13.524287#13302]信息--:注册转换处理器为web1:d671ebce-bf76-4917-b504-ffd5924994f2 i,[2017-06-20t20:25:13.529857#13302]信息--:已注册6个示例:web11:86472d4d-cc95-4a5d-bc52-d1c97a8a9c34,web1:d671ebce-bf76-4917-b504-ffd5924994f2,web14:818a5194-bb51-48d4-bd59-2221a4d3c7ac,web12:11e3f37e-5612-4306-bb1d-bf831da42052,web13:8ace8116-09a4-451c-80b2-8b199ebf45be,web10:8b17b591-9cb0-4193-a460-967ec30cc48c。绑定程序:未能加载命令:/home/deploy/apps/test/current/exe/tracking-events-kafka-consumer.rb(/home/deploy/apps/test/current/exe/tracking-events-kafka-consumer.rb)nomethoderror:未定义的方法 length' for nil:NilClass /home/deploy/apps/test/shared/bundle/ruby/2.3.0/bundler/gems/kafka-consumer-268309adaabe/lib/kafka/consumer.rb:130:in 管理用户分区
/home/deploy/apps/test/shared/bundle/ruby/2.3.0/bundler/gems/kafka-consumer-268309adaabe/lib/kafka/consumer.rb:88:in block in each' I, [2017-06-20T20:25:15.320951 #13363] INFO -- : Registered for conversions-processor as web1:15494044-ddf7-4702-9578-ab828be62478 I, [2017-06-20T20:25:15.325198 #13363] INFO -- : 6 instances have been registered: web13:8ace8116-09a4-451c-80b2-8b199ebf45be, web12:11e3f37e-5612-4306-bb1d-bf831da42052, web10:8b17b591-9cb0-4193-a460-967ec30cc48c, web11:86472d4d-cc95-4a5d-bc52-d1c97a8a9c34, web14:818a5194-bb51-48d4-bd59-2221a4d3c7ac, web1:15494044-ddf7-4702-9578-ab828be62478. bundler: failed to load command: /home/deploy/apps/test/current/exe/tracking-events-kafka-consumer.rb (/home/deploy/apps/test/current/exe/tracking-events-kafka-consumer.rb) NoMethodError: undefined method 长度'nil:nilclass
/home/deploy/apps/test/shared/bundle/ruby/2.3.0/bundler/gems/kafka-consumer-268309adaabe/lib/kafka/consumer.rb:130:in manage_partition_consumers' /home/deploy/apps/test/shared/bundle/ruby/2.3.0/bundler/gems/kafka-consumer-268309adaabe/lib/kafka/consumer.rb:88:in 各挡
如果我在一个盒子上停止消费者-我可以在一个先前失败的盒子上成功地启动它。似乎我的配置一次只允许注册5个消费者?
我的问题是,为什么会这样?我该怎么修呢?
如有任何建议或见解,我们将一如既往,不胜感激!!
谢谢

uqdfh47h

uqdfh47h1#

看来,你所有的消费者都在同一个消费群体,订阅同一个主题,只有5个partitons。如果你想在50个消费者身上分配消费费用,你必须用50个分区来配置你的主题。

相关问题