上一篇地址：持续总结中！2024年面试必问 20 道 Kafka面试题（八）-CSDN博客
十七、Kafka中如何判断一个Broker是否还有效？
在Kafka中，Broker是负责维护数据，并处理生产者的数据推送和消费者的数据拉取的服务器。判断一个Broker是否还有效，可以从以下几个方面进行：
Zookeeper注册信息： Kafka的Broker在启动时会在Zookeeper上注册自己的信息，包括IP地址和端口等。如果Broker失效，它将无法与Zookeeper保持会话，其注册信息会过期并从Zookeeper中删除。
JMX指标： Kafka提供了JMX（Java Management Extensions）监控，可以通过JMX连接到Broker并查询各种运行时指标，如内存使用、CPU使用、垃圾回收情况等。如果Broker失效，这些指标将不再更新。
Kafka控制器： Kafka集群中的控制器（Controller）负责管理集群的元数据和分区分配。如果Broker失效，控制器会检测到并触发重新分配分区和副本。
消费者和生产者的错误反馈： 如果Broker失效，尝试连接到该Broker的生产者和消费者将会收到错误反馈，如连接超时或无法获取元数据等。
日志文件： 检查Broker的日志文件，如服务器日志或系统日志，可以发现错误或异常信息，这些信息可能表明Broker存在问题。
健康检查API： Kafka提供了一个健康检查API（/health），可以返回Broker的健康状态。如果调用此API没有得到预期的响应，可能表明Broker失效。
网络连通性： 使用网络工具（如ping或telnet）检查Broker的IP地址和端口是否可达。如果无法连接，Broker可能已经失效。
监控系统： 使用专门的监控系统（如Prometheus、Grafana等）可以设置告警，当Broker的某些关键指标超出正常范围时，监控系统会发出警告。
手动检查： 如果自动化方法不可用或不可靠，可以手动检查Broker的状态。例如，尝试使用命令行工具（如kafka-topics.sh）与Broker进行交互。
集群状态： 检查Kafka集群的状态，如使用
kafka-topics.sh --describe命令查看所有主题的分区和副本状态，如果发现有分区的领导者不可用，可能表明对应的Broker失效。
通过上述方法，可以有效地判断Kafka中的Broker是否还有效。在生产环境中，通常会结合多种方法和自动化工具来监控和管理Broker的状态。
十八、Kafka可接收的消息最大默认多少字节，如何修改？
在Kafka中，消息大小的限制由几个配置参数决定，这些参数可以在Broker端和生产者端进行设置：
message.max.bytes：这是Broker端的配置参数，它决定了Broker能够接收的最大消息大小（以字节为单位）。默认值通常为1000000字节（即1MB）。max.request.size：这也是Broker端的配置参数，它定义了Broker能够接收的最大请求大小。这个值必须大于message.max.bytes，否则生产者无法发送达到message.max.bytes大小的消息。默认值通常为1048576字节（即1MB）。batch.size：这是生产者端的配置参数，它定义了生产者在发送批次之前可以积累的最大数据量（以字节为单位）。这个值影响着内存使用和延迟。
要修改Kafka可接收的消息最大默认大小，你可以按照以下步骤操作：
Broker端：
- 编辑Kafka的配置文件
server.properties。 - 找到
message.max.bytes和max.request.size参数。 - 将
message.max.bytes设置为你想要的最大消息大小（例如，10 * 1024 * 1024表示10MB）。 - 确保
max.request.size的值大于或等于新的message.max.bytes值。
生产者端：
- 如果生产者代码是使用配置文件的，同样编辑其配置文件。
- 如果是直接在代码中设置，找到生产者配置对象并修改
batch.size参数。 - 调整生产者发送消息的逻辑，以确保单个消息大小不超过Broker端设置的
message.max.bytes限制。
示例： 假设你想要将消息大小限制提高到10MB，你可以这样设置：
在server.properties中：
message.max.bytes=10485760
max.request.size=10485760在生产者代码中（以Java为例）：
Properties props = new Properties();
props.put("bootstrap.servers", "BROKER_LIST");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("batch.size", 10485760); // 设置生产者的batch.size
KafkaProducer<String, String> producer = new KafkaProducer<>(props);请注意，增加消息大小限制可能会对性能和资源使用产生影响，因此需要谨慎考虑。同时，确保所有相关的Kafka组件和依赖服务（如Zookeeper）都已更新并重新启动，以应用新的配置。
