如何通过Postman读取Kafka消息并测试不同生产者的消息

• 用Kafka自带命令行工具模拟多生产者：
  打开两个终端窗口，分别启动带唯一标识的生产者，给每个实例指定不同的client.id来区分：
  kafka-console-producer.sh --broker-list localhost:9092 --topic test-topic --producer-property client.id=producer-1
kafka-console-producer.sh --broker-list localhost:9092 --topic test-topic --producer-property client.id=producer-2
  发送消息后，就能通过元数据区分不同生产者的输出。
• 查看消息的生产者来源：
  用消费者工具消费时开启元数据打印，就能看到每条消息对应的生产者标识：
  kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-topic --from-beginning --property print.headers=true
  消息的headers里会包含client.id，直接对应发送它的生产者。
• 用可视化Kafka管理工具：
  像AKHQ、Kafka Manager这类UI工具，能直接创建多个生产者实例发送消息，在消费面板里可以直观看到每条消息的生产者ID、客户端ID等元数据，不用敲命令就能区分来源。

Postman本身没有原生Kafka支持，可借助以下两种方式实现：

• 借助Kafka REST Proxy：
  1. 先启动Confluent REST Proxy或其他开源Kafka REST服务，确保它能连接你的Kafka集群。
  2. 在Postman里新建GET请求，URL填http://<REST代理地址>:8082/topics/你的主题名/partitions/0/messages
  3. 请求头添加Accept: application/vnd.kafka.json.v2+json，指定返回格式。
  4. 可添加查询参数控制消费，比如offset=0从起始位置读取，max_bytes=1024限制单次读取的字节数。
     发送请求后，响应里会包含消息内容、偏移量，以及生产者相关元数据。
• 用Postman脚本结合Kafka客户端库：
  1. 在Postman的Pre-request Script或Tests标签里编写Node.js脚本，用kafka-node库连接Kafka：

  const kafka = require('kafka-node');
  const client = new kafka.KafkaClient({kafkaHost: 'localhost:9092'});
  const consumer = new kafka.Consumer(
    client,
    [{ topic: 'test-topic', partition: 0, offset: 0 }],
    { autoCommit: false }
  );
  
  consumer.on('message', msg => {
    console.log('收到的Kafka消息:', msg);
    pm.environment.set('kafka_msg', JSON.stringify(msg));
  });
  
  consumer.on('error', err => {
    console.error('消费出错:', err);
  });
  

  2. 运行脚本后，消息会打印在Postman控制台，也能存入环境变量供后续请求调用。

内容的提问来源于stack exchange，提问作者Igor Martakov