Kafka中出现“连接到节点1001（localhost/127.0.0.1:9092）无法建立，代理可能不可用”错误怎样解决？

这个错误通常是因为代理没有启动或连接不上而导致的。可以使用以下几种方式来解决：

1. 检查代理是否启动，以及代理的配置是否正确。

2. 确认 Kafka 代理端口号是否正确，并使用正确的主机名或 IP 地址进行连接。

3. 检查防火墙设置，确保它们不会阻止 Kafka 的网络流量。

以下是使用 Java 编写的示例代码来创建 Kafka 生产者和消费者，供参考：

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Collections;
import java.util.Properties;

public class KafkaExample {
    public static void main(String[] args) {
        String kafkaBrokers = "localhost:9092";
        String kafkaTopic = "test-topic";
        String kafkaGroup = "test-group";
        Properties props = new Properties();
        props.put("bootstrap.servers", kafkaBrokers);
        props.put("group.id", kafkaGroup);
        props.put("key.serializer", StringSerializer.class);
        props.put("value.serializer", StringSerializer.class);
        props.put("key.deserializer", StringDeserializer.class);
        props.put("value.deserializer", StringDeserializer.class);


        //创建Kafka 生产者

        KafkaProducer<String, String> producer = new KafkaProducer<String, String>(props);
        ProducerRecord<String, String> record = new ProducerRecord<String, String>(kafkaTopic, "Hello World");
        producer.send(record);
        producer.flush();
        producer.close();

        //创建Kafka 消费者
        KafkaConsumer<String, String> consumer = new KafkaConsumer<String, String>(props);
        consumer.subscribe(Collections.singletonList(kafkaTopic));
        while (