Kafkaretries=0give'Failedtoobtainpartitioninformation'error

在Kafka生产者的配置中，如果将retries属性设置为0，则Kafka在尝试发送消息到分区时会立即失败并返回“Failed to obtain partition information”错误。此错误通常是因为分区未被分配给生产者或没有可用的分区时发生的。

解决此问题的方法是将retries属性设置为1或更高的值。这将允许Kafka在发送消息到分区时进行重试。例如，将retries属性设置为3，表示每条消息将尝试发送三次。

以下是使用Java Kafka Producer的代码示例，将retries属性设置为3：

import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class KafkaProducerExample {
   public static void main(String[] args) {
      Properties props = new Properties();
      props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
      props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
      props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
      props.put(ProducerConfig.RETRIES_CONFIG, 3);

      KafkaProducer<String, String> producer = new KafkaProducer<>(props);

      for (int i = 0; i < 10; i++) {
         ProducerRecord<String, String> record = new ProducerRecord<>("mytopic", "key-" + i, "value-" + i);
         producer.send(record);
      }
      producer.close();
   }
}