除非我重新启动ubuntu内核，否则kafka代理会超时连接到zoo的管理员
很抱歉，但我绞尽脑汁想弄清楚这一点。我的kafka经纪人说等待连接到zookeper，然后关闭（超时）。我检查了经纪人配置/端口是否netstat等也确认了zookeper设置。但是如果我重新启动我的ubuntu内核（kafka经纪人正在运行的地方），一切都很好。动物园管理员是Linux薄荷。请有人建议哪里的日志文件可以给我更多的细节——我做了通常的netstat和lsof运气不好。
共有1个答案
它的 Windows 10 由于某种原因无法识别我的分区 IP。修复了这是我的配置项目。
-
伙计们，如果有人经历过这个问题，请你帮帮我，我一直在绞尽脑汁，但没有成功，我尽可能多地阅读了很多帖子。 场景我有动物园管理员/两个经纪人和一个生产者和消费者在我的本地分区上运行，来自我子网内的不同IP地址，一切都很完美。我的生产者生产-消费者消费生活快乐。 我想在EC2上复制这一点，并在EC2中创建一个kafka代理，并希望该代理连接到我的动物园管理员，但由于某种原因，EC2上的代理无法连接到我。
-
我们在内部云上安装了kafka broker。我们使用zookeeper找到实际的url，并在bootstrap.server配置中提供。现在的问题是，当代理重新启动内部云时，它会使用新的主机端口在动态分配的机器上重新启动。现在，我最初在生产者配置中给出的主机端口无效。 问题是如何在不重新启动的情况下重新加载此配置。 注意：我知道这是一个糟糕的设计主机代理，它可以在不同的机器上重新启动，但这就是现
-
我正在为Kafka工作客户：librdkafka。图书馆在这里https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_example.cpp.我的程序正在向代理写入2000000条消息。在此过程中，我重新启动了代理。有时，没有消息无法传递到代理。有时，大约100000条消息未能传递到代理。队列缓冲。最大消息数=1000
-
我读过这段文档： RabbitMQ自动连接/拓扑恢复 自Spring AMQP的第一个版本以来，该框架在代理失败的情况下提供了自己的连接和通道恢复。此外，如第3.1.10节“配置代理”所述，RabbitAdmin将在重新建立连接时重新声明任何基础结构bean（队列等）。因此，它不依赖amqp客户端库现在提供的自动恢复。Spring AMQP现在使用4.0。amqp客户端的x版本，默认情况下已启用自
-
我将kafka-connect docker映像()部署到ECS/fargate，为我的ECS服务分配了一个安全组，该安全组允许传入的zooper keeper和kafka bootstrap服务器通信量（纯文本和TLS)，并分配了一个IAM角色，该角色允许我的ECS任务对MSK集群运行kafka操作，但connect集群在尝试从MSK集群获取代理列表时仍会超时。 在AWS中，kafka conn
-
问题内容： 这是我的配置： 根据此处找到的logback文档（http://logback.qos.ch/manual/appenders.html#TimeBasedRollingPolicy），文件将根据我的fileNamePattern 每分钟翻转一次。 我观察了它是如何工作的，这是我的发现： 它不会在很短的时间内创建日志文件。 当新日志到达时，它只会为前一分钟创建一个日志文件。（例如，我在