从这个生成器代码中,我得到了输出,因为所有10条消息都要转到10个分区。但问题是每个分区都有10条消息。我想要的是每个分区只能得到一条消息,即分区应该随机地得到一条消息。或者,如果我们有50条消息,那么这些消息应该随机分配给这些分区,而不是每个分区得到50条消息。(PartitionInfo partitioninfo : infoList){
p
我正在使用kafka向消费者发送消息。但是,由于某些原因,当我使用producer.send(record, new MyProducerCallback());将记录发送到一个主题中时,该主题的使用者不会收到该记录。但是,当我使用RecordMetadata m = producer.send(record).get();发送记录时,记录会完美地到达消费者那里。回调方法曾经有效,但现在不起作用了。
我们有一个用例将一组具有相同groupId但与MessageSequenceNumber不同的消息放在一起。这是用于对消息进行逻辑排序的分组,以便在接收端,接收方可以根据组顺序对所有消息进行分组。Actually put messages to Queue) return true;现在,我想在数组中的所有消息中添加一个唯一的