apache-kafka 在Kafka中,从具有任何分区号的生产者发送消息仍然有效

k10s72fa  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(155)

为什么如果我在生成器的构造函数方法中设置任何数字作为分区,即使分区不存在,它也会工作,并且发送消息,它会自动创建分区吗?
如:

await producer.connect();
        await producer.send({
            topic: "my-topic",
            messages: [{ value: JSON.stringify(data) }],
            partition: 200,
        });

之后,我可以正常消费它没有错误。

5hcedyr0

5hcedyr01#

已解决,分区应在消息块内。thanks @valath

相关问题