阅读kafka主题并通过prometheus的Rest API公开数据以抓取( Nodejs)

const kafka = require('kafka-node');
const request = require('request');

// Kafka配置
const kafkaHost = 'your_kafka_host:9092';
const topic = 'your_kafka_topic';

// Prometheus配置
const prometheusURL = 'http://your_prometheus_url/api/v1/query';
const query = 'your_prometheus_query';

// 创建Kafka消费者
const Consumer = kafka.Consumer;
const client = new kafka.KafkaClient({ kafkaHost });
const consumer = new Consumer(client, [{ topic }]);

// 监听Kafka消息
consumer.on('message', async (message) => {
  const data = JSON.parse(message.value);

  // 发送Prometheus查询请求
  const prometheusQueryURL = `${prometheusURL}?query=${query}`;
  request(prometheusQueryURL, (error, response, body) => {
    if (!error && response.statusCode === 200) {
      const result = JSON.parse(body);
      // 处理查询结果
      console.log(result);
    } else {
      console.error('Failed to fetch data from Prometheus');
    }
  });
});

// 错误处理
consumer.on('error', (error) => {
  console.error('Kafka consumer error:', error);
});