为什么如果我在生成器的构造函数方法中设置任何数字作为分区,即使分区不存在,它也会工作,并且发送消息,它会自动创建分区吗?
如:
await producer.connect();
await producer.send({
topic: "my-topic",
messages: [{ value: JSON.stringify(data) }],
partition: 200,
});
之后,我可以正常消费它没有错误。
1条答案
按热度按时间5hcedyr01#
已解决,分区应在消息块内。thanks @valath