消息 Kafka被当作传统消息中间件的替代品。消息中间件的使用原因有多种（从数据生产者解耦处理，缓存未处理的消息等）。与大多数消息系统相比，Kafka具有更好的吞吐量，内置的分区，多副本和容错功能，这使其成为大规模消息处理应用程序的良好解决方案。 在我们的经验中，消息的使用通常是相对较低的吞吐量，但可能需要较低的端到端延迟，并且通常需要强大的持久性保证，这些Kafka都能提供。 在这些要点中，Kafka可与传统消息系统（如ActiveMQ或RabbitMQ）媲美。 网站行为跟踪 Kafka的初衷就是能够将用户行为跟踪管道重构为一组实时发布-订阅数据源。这意味着网站活动（页面浏览量，搜索或其他用...

5.设计与实现(IMPLEMENTATION) 5.1API设计 生产者APIS 生产者API包含2个producers-kafka.producer.SyncProducer和 kafka.producer.async.AsyncProducer。示例代码如下： classProducer{ /Sendsthedata,partitionedbykeytothetopicusingeitherthe/ /synchronousortheasynchronousproducer/ /使用同步或者异步的生产者，发送单条消息至由key所对应的topic的分区/ publicvoidsend(ka...