如何使用节点JS从kafka消息中读取包含加密元数据的头部

const kafka = require('kafka-node');
const Consumer = kafka.Consumer;
const client = new kafka.KafkaClient({ kafkaHost: 'your_kafka_host' });

const consumer = new Consumer(
  client,
  [{ topic: 'your_topic_name', partition: 0 }],
  { autoCommit: false }
);

consumer.on('message', function (message) {
  const encryptedHeader = message.value.slice(0, 16); // 假设加密头部为前16个字节
  const decryptedHeader = decrypt(encryptedHeader); // 解密加密头部

  const payload = message.value.slice(16); // 假设有效载荷从第17个字节开始
  // 处理消息的逻辑
});

function decrypt(encryptedHeader) {
  // 解密逻辑
  return decryptedHeader;
}