Client HealthCheck：如果broker关闭，则检查消费者/生产者
简而言之，我如何在生产者/消费者苏德上找到相关经纪人的健康状况。
共有1个答案
最后，我把问题分成几个检查。
>
你能联系到经纪人吗？AdminClient.DescripeCluster适用于此
你能说明你所用的主题吗？AdminClient.Descripetopic可以执行此操作
对于消费者来说，看看重新平衡将会发生的条件（例如轮询之间的处理时间很长），然后你就能快速识别出对他们来说“不健康”意味着什么。
我写的一些概念
- DropWizard-Kafka（也有生产者和消费者检查）
- 雷莫拉
-
最近，我们与Kafka消费者和生产商之间出现了一些性能问题。我们在scala中使用Kafka Java API。打开和关闭消费者和生产者对象的良好做法是什么？我认为这是一个非常开放的问题，正确的答案总是，但我正在尝试对此进行推理。 消费者可以长时间运行连接并保持开放吗？ 当我们完成信息生成时，生产者是否应该关闭？
-
当所有的经纪人都起来的时候，一切都是好的。但是，如果我先杀死（按开始顺序），代理消息会被发送到代理，但使用者不能接收到任何消息，消息不会丢失。启动该代理后，使用者立即接收消息。 关闭broker实例后的使用者日志： 再次启动丢失的代理后的使用者日志： 谢谢
-
现在我正面临着连接生产者/消费者的问题。 > 我使用以下命令创建了一个客户端密钥存储库, 将CA证书添加到密钥库, 警告与节点-1的连接在身份验证期间终止。这可能表明身份验证由于凭据无效而失败。（org.apache.kafka.clients.NetworkClient） 怀疑我在客户端配置中缺少了什么。如有任何帮助，将不胜感激。
-
本教程演示了如何发送和接收来自Spring Kafka的消息。 首先创建一个能够发送消息给Kafka主题的Spring Kafka Producer。 接下来，我们创建一个Spring Kafka Consumer，它可以收听发送给Kafka主题的消息。使用适当的键/值序列化器和解串器来配置它们。 最后用一个简单的Spring Boot应用程序演示应用程序。 下载并安装Apache Kafka 要
-
生产者线程与消费者线程使用信号量同步 生产者线程与消费者线程使用信号量同步 源码/* * Copyright (c) 2006-2018, RT-Thread Development Team * * SPDX-License-Identifier: Apache-2.0 * * Change Logs: * Date Author Notes * 2018-08-24 yangjie the f
-
所谓的生产者消费者模型就是 某个模块（函数）负责生产数据，这些数据由另一个模块来负责处理 一般生产者消费者模型包含三个部分 生产者、缓冲区、消费者 为什么生产者消费者模型要含三个部分？直接生产和消费不行么？ 一个案例说明一切 生产者好比现实生活中的某个人 缓冲区好比现实生活中的邮箱 消费者好比现实生活中的邮递员 如果只有生产者和消费者, 那么相当于只有写信的人和邮递员，那么如果将来过去的邮递员离职