以下是一个AWS Node JS kafka消费者解密kafka消息的代码示例。该示例使用KMS（密钥管理服务）动态解密消息。

1. 安装必要的依赖项：

npm install kafka-node aws-sdk --save

2. 导入必要的模块：

const AWS = require('aws-sdk');
const kafka = require('kafka-node');

3. 设置AWS配置和KMS客户端：

AWS.config.update({region: 'your-aws-region'});
const kms = new AWS.KMS();

4. 创建一个消费者实例：

const Consumer = kafka.Consumer;
const client = new kafka.Client('your-zookeeper-address');
const consumer = new Consumer(
  client,
  [{ topic: 'your-topic', partition: 0 }],
  { autoCommit: true }
);

5. 为消息设置解密函数：

const decryptMessage = (encryptedMessage, callback) => {
  const params = {
    CiphertextBlob: Buffer.from(encryptedMessage, 'base64')
  };
  kms.decrypt(params, (err, data) => {
    if (err) callback(err);
    else {
      callback(null, data.Plaintext.toString('utf-8'));
    }
  });
};

6. 监听消息并解密：

consumer.on('message', (message) => {
  decryptMessage(message.value, (err, decryptedMessage) => {
    if (err) console.error(err);
    else console.log(decryptedMessage);
  });
});

7. 监听错误：

consumer.on('error', (err) => {
  console.error(err);
});