通过该脚本，可以查看与 Kafka Broker 交互时支持的 API 版本，帮助调试和确认不同版本的兼容性问题。Kafka 集群的核心是各个 Kafka Broker，每个 Broker 的状态直接影响集群的整体健康状况。它会返回支持的 API 的版本信息，以及客户端与 Broker 之间兼容性的问题。Kafka 的日志文件通常包含详细的启动和运行信息，可以通过日志文件进一步确认 Kafka 服

错误通常由主题不存在、网络问题或配置不当引起。通过检查主题状态、优化客户端配置以及确保网络连通性，可以有效解决该问题。建议提前创建主题，并优化客户端和 Broker 配置，以减少此类错误的发生概率。该错误表明 Kafka 客户端（生产者或消费者）在尝试与 Kafka Broker 通信时，未能在指定时间内（默认 60 秒）获取到指定主题的元数据。元数据包含主题的分区、Leader 等信息。如果主题

Kafka 连接超时是指客户端（如生产者、消费者）与 Kafka Broker 之间的连接在规定的时间内未能成功建立或维持，导致请求失败。Kafka 消费者消费时间超过限制问题通常发生在消费者处理消息的时间过长，导致消费请求超时或消费者无法及时处理消息，进而影响整个消费者组的消费效率。如果 Kafka 集群的负载过高，可以考虑使用负载均衡（如 Nginx、HAProxy）来均衡客户端的连接请求，避

Kafka 消费者组在以下情况下会触发rebalance消费者加入或退出：如果一个消费者加入或退出消费者组，Kafka 会重新分配分区给现有的消费者，触发 rebalance。分区变动：如果 Kafka 主题的分区数发生变化（增加或删除分区），消费者组也会触发 rebalance。消费者失联：如果某个消费者在指定的时间内没有发送心跳，Kafka 会认为它失联，并触发 rebalance。消费者处理

这个错误表明，Kafka 生产者在发送消息时，单条消息的序列化大小超出了 Kafka 允许的最大请求大小（默认 1MB，即 1,048,576 字节）。

是 Java 程序开发的核心工具包，包含了开发 Java 应用程序所需的所有资源。它为开发者提供了编写、编译、调试和运行 Java 程序的工具和类库。JDK 的主要组成部分是 Java 程序运行的环境，包含了 JVM 和运行 Java 程序所需的核心类库。JDK 包含了 JRE，因此开发者在使用 JDK 时，实际上也已经拥有了 JRE。Java 编译器（javac）将 Java 源代码（.java

是 Java 程序开发的核心工具包，包含了开发 Java 应用程序所需的所有资源。它为开发者提供了编写、编译、调试和运行 Java 程序的工具和类库。JDK 的主要组成部分是 Java 程序运行的环境，包含了 JVM 和运行 Java 程序所需的核心类库。JDK 包含了 JRE，因此开发者在使用 JDK 时，实际上也已经拥有了 JRE。Java 编译器（javac）将 Java 源代码（.java