Kafka生产者 - 在集群中的经纪人重启后无法下载/刷新元数据

在Kafka生产者中，如果在集群中的经纪人重启后无法下载或刷新元数据，可以尝试以下解决方法：

1. 使用KafkaAdminClient刷新元数据：

   Properties props = new Properties();
   props.put("bootstrap.servers", "localhost:9092");
   KafkaAdminClient adminClient = KafkaAdminClient.create(props);
   adminClient.refreshMetadata(Collections.singleton("topicName"));
   

2. 在创建生产者之前设置retries参数：

   Properties props = new Properties();
   props.put("bootstrap.servers", "localhost:9092");
   props.put("retries", 5);
   props.put("retry.backoff.ms", 1000);
   KafkaProducer<String, String> producer = new KafkaProducer<>(props);
   

3. 在发送消息时处理ProducerFencedException异常：

   try {
       producer.send(new ProducerRecord<>("topicName", "key", "value")).get();
   } catch (ExecutionException e) {
       if (e.getCause() instanceof ProducerFencedException) {
           // 处理ProducerFencedException异常，例如重新创建生产者
       }
   }
   

4. 在生产者配置中设置metadata.max.age.ms参数：

   Properties props = new Properties();
   props.put("bootstrap.servers", "localhost:9092");
   props.put("metadata.max.age.ms", 5000);
   KafkaProducer<String, String> producer = new KafkaProducer<>(props);
   

5. 检查Kafka集群的网络连接和配置是否正确，确保生产者可以正确连接到集群。

以上是一些常见的解决方法，可以根据具体情况选择适合的方法来解决Kafka生产者在经纪人重启后无法下载或刷新元数据的问题。