直接从 ActiveMQ Artemis 副本消费
Consume directly from ActiveMQ Artemis replica
在使用 HA/Data 复制功能的集群场景中,有没有一种方法可以让消费者从从节点 consume/fetch 获取数据,而不是总是联系主节点(该特定队列的主节点) ?
如果您考虑可伸缩性,让所有消费者调用一个节点负责成为特定队列的主节点,这意味着所有流量都流向一个节点。
Kafka 允许消费者从最近的节点获取数据,如果该节点包含领导者的副本,ActiveMQ 上是否有类似的东西?
简而言之,没有。消费者只能从主动经纪人消费,奴隶经纪人不是主动的,他们是被动的。
如果您想提高可伸缩性,您可以向集群添加额外的代理(或 HA 代理对)。也就是说,我建议仔细进行基准测试,以确认您在增加集群大小之前确实 需要 额外的容量。根据用例,单个 ActiveMQ Artemis 代理每秒可以处理数百万条消息。
据我了解,Kafka 的语义与 ActiveMQ Artemis 等“传统”消息代理有很大不同,因此比较并不是特别恰当。
在使用 HA/Data 复制功能的集群场景中,有没有一种方法可以让消费者从从节点 consume/fetch 获取数据,而不是总是联系主节点(该特定队列的主节点) ?
如果您考虑可伸缩性,让所有消费者调用一个节点负责成为特定队列的主节点,这意味着所有流量都流向一个节点。
Kafka 允许消费者从最近的节点获取数据,如果该节点包含领导者的副本,ActiveMQ 上是否有类似的东西?
简而言之,没有。消费者只能从主动经纪人消费,奴隶经纪人不是主动的,他们是被动的。
如果您想提高可伸缩性,您可以向集群添加额外的代理(或 HA 代理对)。也就是说,我建议仔细进行基准测试,以确认您在增加集群大小之前确实 需要 额外的容量。根据用例,单个 ActiveMQ Artemis 代理每秒可以处理数百万条消息。
据我了解,Kafka 的语义与 ActiveMQ Artemis 等“传统”消息代理有很大不同,因此比较并不是特别恰当。