使用nestjs transporter设置kafka行键

Question

我使用NESTJS Kafka transporter得到了一些很好的结果。消息被很好地序列化并保存在value属性下的主题中。即value.id = 0，value.name = "John Does"，value.topup="10“等。

使用nestjs代理客户端，如何设置消息的键(而不仅仅是值)？

this.client.emit<string>('userevents', JSON.stringify(event));

在方法签名中，我没有看到任何可以帮助我设置密钥的参数。

你们是怎么做到的？谢谢你的任何提示。

Answer 1

NestJS官方网站没有说明如何使用client.emit放置密钥(用于分区)。我需要一些时间来弄清楚这一点：

await this.client.emit('TOPIC_NAME',{
  key: 'your-key',
  value: { test: 123 },
});