本文首发于 vivo互联网技术 微信公众号 [链接] 作者简介：郑志彬，毕业于华南理工大学计算机科学与技术（双语班）。先后从事过电子商务、开放平台、移动浏览器、推荐广告和大数据、人工智能等相关开发和架构。目…

“””Author:YjxTime:2019-8-17 16:26″””from kafka import KafkaProducerfrom kafka import KafkaConsumerfrom threading import Threadimport time

1 Kafka概念一个分布式消息队列，具有高性能、持久化、多副本备份、横向扩展能力。生产者往队列里写消息，消费者从队列里取消息进行业务逻辑。1.1 kafka读、发消息的方式kafka对外使用topic的概念，生产者往topic…

这几天简单学习了一下Kafka，看了一些书，也查了一些资料，结合这些，我简单总结了一下Kafka的一些基础知识,以此作记录～老规矩，抛出我们这篇文章的三个问题：

MQTT 与 Kafka 是完全不同的两个东西， MQTT 是协议，是一个技术标准，由 OASIS 技术委员会的成员（其成员多数为 IBM 和微软的顶级工程师）制订。而 Kafka 是已经实现的开源流处理平台，最早由 LinkedIn 开发，于…

kafka是一款开源、追求高吞吐、实时性，可持久化的流式消息队列，可同时处理在线（消息）与离线应用(业务数据和日志)。在如今火热的大数据时代，得到了广泛的应用。

Kafka 学习笔记 极客时间–胡夕 Kafka使用一个叫Franz Kafka的文学家的名字用来命名的。 Kafka是一款开源的消息引擎系统。也是一个分布式流处理平台。 Kafka同时支持点对点模型以及发布/订阅模型。 为什么要使用K…

EMQ X 3.2 版本引入了 “规则引擎” 功能，支持在 EMQ X Broker 筛选终端上报的数据，处理后流至后端数据库或其他的消息队列。本篇以具体场景来说明 “如何使用规则引擎将消息转发至 Kafka”

ActiveMQ专题 （面试题+答案领取方式见主页） 什么是 ActiveMQ? ActiveMQ 服务器宕机怎么办？ 丢消息怎么办？ 持久化消息非常慢。 消息的不均匀消费。 死信队列。 ActiveMQ 中的消息重发时间间隔和重发次数吗？ R…

最近发现一个Kafka producer异步发送在某些情况会阻塞主线程，后来在排查解决问题过程中发现这可以算是Kafka的一个说明不恰当的地方。