Yikes! Ask timed out on [ActorSelection[Anchor(akk://kafka-manager-system/),Path(/user/kafka-manager/kafka1/kafka-state)]] after [2000 ms]. Message of type [kafka.manager.model.ActorModel$KSGetBrokers$] was sent by[Actor[akka://kafka-manager-system/user/kafka-manager/kafka1#- 11708675331]. A typical
我有3个经纪人(brker1,broker2和broker3),我的卡夫卡管理器能够连接到broker2,但不能连接到其余的两个经纪人(broker1和broker3)。我也重新启动了kafka-manager、broker1和broker3,但仍然没有连接到这两个代理。
注意:- kafka在3个代理上运行
这是我从kafka-manage得到的日志
[error] k.m.a.c.BrokerViewCacheActor - Failed to get broker metrics for BrokerIdentity(3,broker3,9092,9999,false)
java.rmi
我曾在“拉拉”中使用Rdkafka向mongodb插入记录。首先,我使用了两个经纪人和一个消费者,我的结果是每分钟121000记录。想要更多的消费者从生产者到消费者的信息,由重复的消费者在代码和它似乎没有工作。如何添加更多的使用者来处理更多的请求插入?
这是我的代码使用者。
<?php
namespace App\Console\Commands;
use App\Core\BillLadingReport\BillLadingReport;
use Illuminate\Console\Command;
use RdKa