Confluent云环境中通过REST代理生产记录时出错

1. 确认REST代理的地址、端口以及生产者的topic名称和认证信息是否正确。
2. 检查生产者的代码，确认必要的配置是否正确设置，如序列化器、Kafka集群地址、生产者ACK的方式和等待时间等。

示例代码：

// 生产者配置 Properties properties = new Properties(); // 指定Kafka集群地址 properties.put("bootstrap.servers", "kafka-cluster-url:9092"); // 生产者ACK方式设置为“所有” properties.put("acks", "all"); // 设置生产者等待时间 properties.put("delivery.timeout.ms", 60000); // 设置Key和Value的序列化器 properties.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

// 创建生产者 KafkaProducer<String, String> producer = new KafkaProducer<>(properties);

// 生产消息 String topicName = "my-topic"; ProducerRecord<String, String> record = new ProducerRecord<>(topicName, "key", "value");

try { RecordMetadata metadata = producer.send(record).get(); System.out.println("Message sent successfully: " + metadata.toString()); } catch (InterruptedException | ExecutionException e) { System.out.println("Error while producing message: " + e.getMessage()); } finally { producer.close(); }