kafkaJs中如何设置默认值？

在kafkaJs中设置默认值可以使用第三个参数来传递选项对象。例如，如果要设置消息的默认分区，则可以将defaultPartition选项设置为所需值。示例如下：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['localhost:9092'],
  // 设置默认值
  defaultPartition: 0
})

const producer = kafka.producer()
await producer.connect()

await producer.send({
  topic: 'my-topic',
  messages: [
    { value: 'Hello World!' },
    { value: 'Hi' },
  ],
  // 指定分区覆盖默认值
  partition: 1
})

await producer.disconnect()

在上面的示例中，我们将defaultPartition选项设置为0，这意味着如果消息未指定分区，则它将被发送到分区0。但是，我们在发送消息时也可以显式指定分区，以覆盖默认值。