何时使用Apache kafka而不是ActiveMQ[关闭]

Question

想改进这个问题吗 通过编辑此帖子，更新问题，以便用事实和引用来回答。

最初的关闭原因未得到解决

我正在开发Apache Kafka。我想知道哪一个更好：Kafka和ActiveMQ。这两种技术的主要区别是什么？我想在Spring MVC中实现Kafka。

Answer 1

我每周都会听到这个问题……虽然ActiveMQ（通常像IBM MQ或JMS）用于传统消息传递，但Apache Kafka被用作流平台（数据的消息传递分布式存储处理）。两者都是为不同的用例构建的。

您可以将Kafka用于“传统的消息传递”，但不能将MQ用于Kafka特定的场景。

文章“Apache Kafka vs. Enterprise Service Bus （ESB） — 朋友、敌人还是友敌？（https://www.confluent.io/blog/apache-kafka-vs-enterprise-service-bus-esb-friends-enemies-or-frenemies/）“讨论了为什么 Kafka 没有竞争力，而是对集成和消息传递解决方案（包括 ActiveMQ）的补充以及如何集成两者。

Answer 2

Kafka架构与ActiveMQ不同。

在Kafka中，producer将向topic发布消息，topic是特定类型的消息流。消费者将通过拉取数据来订阅经纪人的一个或多个主题。

主要区别:

>

ActiveMQ Broker必须维护每条消息的传递状态，从而导致吞吐量降低。与 ActiveMQ 不同，Kafka 生产者不会等待来自代理的确认，并且以代理可以处理的速度发送消息。如果代理可以像生产者一样快地处理消息，则总体吞吐量将很高。

Kafka有更有效的存储格式。平均而言，Kafka中每条消息的开销为9个字节，而ActiveMQ中为144个字节。

在 AcitveMQ 中，生产者向代理发送消息，代理向所有消费者推送消息。制作者有责任确保消息已传递。在 Kafka 中，Consumer 将在自己的时间从代理中提取消息。消费者有责任消费它应该消费的消息。

AMQ的慢速消费者会在非持久主题上引起问题，因为他们会迫使代理将旧消息保存在RAM中，一旦RAM填满，就会迫使代理减慢生产者的速度，从而导致快速消费者变慢。Kakfa的慢消费者不会影响其他消费者。

在Kafka-消费者可以倒退到旧的偏移量并重新消费数据。当您修复了一些问题并决定在问题解决后重新播放旧消息时，这很有用。

队列和主题的性能可能会随着 ActiveMQ 中更多使用者的增加而降低。但Kafka并没有增加更多消费者的劣势。

由于分区的复制，Kafka具有高度的可扩展性。它可以确保消息在分区中按顺序传递。

ActiveMQ是传统的消息传递系统，其中Kakfa是指具有大量数据的分布式处理系统，对于流处理是有效的

由于上述效率，Kafka的吞吐量超过了ActiveMQ和RabbitMQ等普通消息传递系统。

更多细节可以在 notes.stephenholiday.com 阅读

编辑：这尤其适合那些认为制作人不会等待经纪人确认的人。他们可以阅读ActiveMQ文档页面

ProducerWindowSize是生产者在等待来自代理的确认消息之前将向代理传输的最大数据字节数，该确认消息表明生产者已经接受了先前发送的消息。

Answer 3

Kafka和ActiveMQ可能有一些重叠，但它们最初是为不同的目的设计的。所以比较它们就像比较苹果和橙子一样。

Kafka

Kafka 是一个分布式流媒体平台，具有非常好的水平扩展能力。它允许应用程序处理和重新处理磁盘上的流数据。由于其高吞吐量，它通常用于实时数据流。

激活MQ

ActiveMQ是一个通用的消息代理，支持多种消息协议，如AMQP、STOMP、MQTT。它支持更复杂的消息路由模式以及企业集成模式。一般来说，它主要用于应用程序/服务之间的集成，尤其是在面向服务的架构中。