生产者A将消息写入Broker A(分区1),生产者B将相同的消息写入Broker A(分区1)。消息或经纪人会怎么样?
我猜是因为有相同的消息,制作人B停止相同的消息,并继续下一部分消息?
我还有一个问题如果你想发送一个电影文件,例如,发送给Kafka Cluster,我可以制作4个制作人并让他们将该电影的不同部分发送到集群吗?例如,制作人A发送电影的第一部分,制作人B发送电影的第二部分,依此类推。 (因为这似乎比一个生产者更有效。)
send()