kafka服务器配置文件中的broker端口不同，但在同一端口上执行

在Kafka服务器配置文件中，可以通过设置listeners属性来配置不同的broker端口。以下是一个使用不同的broker端口的示例配置文件：

# server.properties

# Broker 1配置
listeners=PLAINTEXT://localhost:9092

# Broker 2配置
listeners=PLAINTEXT://localhost:9093

# Broker 3配置
listeners=PLAINTEXT://localhost:9094

在上述示例中，分别使用了9092、9093和9094端口来配置不同的broker。

然后，在代码中，可以使用KafkaProducer和KafkaConsumer来连接到相应的broker端口。以下是一个使用Java代码示例：

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.ConsumerRecord;

import java.util.Properties;

public class KafkaExample {
    public static void main(String[] args) {
        // Producer示例
        Properties producerProps = new Properties();
        producerProps.put("bootstrap.servers", "localhost:9092"); // 连接到Broker 1的端口
        producerProps.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        producerProps.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer<String, String> producer = new KafkaProducer<>(producerProps);
        producer.send(new ProducerRecord<>("my-topic", "key", "value"));
        producer.close();

        // Consumer示例
        Properties consumerProps = new Properties();
        consumerProps.put("bootstrap.servers", "localhost:9093"); // 连接到Broker 2的端口
        consumerProps.put("group.id", "my-group");
        consumerProps.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        consumerProps.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(consumerProps);
        consumer.subscribe(Collections.singletonList("my-topic"));
        while (true) {
            ConsumerRecords<String, String> records = consumer.poll(100);
            for (ConsumerRecord<String, String> record : records) {
                System.out.println("Received message: " + record.value());
            }
        }
    }
}

在上述示例中，Producer连接到了9092端口，而Consumer连接到了9093端口。这样，即使在同一端口上执行，也能正确地连接到相应的broker进行生产和消费操作。你可以根据实际需要修改端口和其他配置项。