我使用KafkaEmbedded (和KafkaTemplate)进行了单元测试,但消息顺序是随机的。有没有人知道这是否合乎逻辑,以及这是否可能是担保顺序?public class KafkaTest {
public static KafkaEmbeddedembeddedKafka = new KafkaEmbedded(
"Kafka in a“一文(at )的作者说:
Kafka为数据的一致性和可用性提供了以下保证:(1)发送到主题分区的消息将按照发送的顺序附加到提交日志中;(2)单个使用者实例将按照它们在日志中出现的顺序查看消息;(3)当所有同步副本都将其应用于其日志时,消息将被“提交”;(4)任何已提交的消息都不会丢失,只要同步副本中至少有一个是活着的。第一和第二保证确保为每个分区保留消息排序。请注意,不能<
根据,XMPP规范保证按接收消息的顺序处理消息,但不一定按照接收消息的顺序传递。即使它们不是按照接收到的顺序传递的,XMPP (正常的聊天或通过发布子扩展)是否保证所有连接的客户端都会以一致的顺序接收消息?例如,如果A, B, C发送了三条消息,而客户端C1在order A, C, B中接收到<message>节,那么客户端C2也会收到order A, C, B中的节吗