建立topic的时候，可以通过指定参数 –replication-factor 设置备份数量。但是，一旦完成建立topic，则无法通过kafka-topic.sh 或者 命令修改replica数量。

接上一篇文章【kafka KSQL】游戏日志统计分析（1），展示一下KSQL WINDOW 功能的使用。 测试用日志数据： {代码…} KSQL三种Window 统计每2分钟内完成对局大于等于3局的玩家 根据时间窗口（Tumbling window）建…

【kafka KSQL】游戏日志统计分析（1） 以游戏结算日志为例，展示利用KSQL对日志进行统计分析的过程。 启动confluent {代码…} 查看kafka主题列表 {代码…} 创建接受游戏结算日志的topic {代码…} 使用生产者命…

topic是逻辑概念，分区（partition）是物理概念，对于用户来说是透明的。producer只需要关心消息网哪个topic发送，而consumer之关系自己订阅哪个topic，不需要关心每条消息存于整个集群的哪个Broker。

初识kafka 初识kafka集群 初识kafka中的生产者与消费者 初识kafka对消息处理与可靠性做出的保证

broker可以理解成一个kafka服务node，是一个运行的kafka服务。broker与broker之间是平等的关系，任意broker都可以down机而不影响其他broker正常工作。kafaka在启动的时候，会将自己的信息同步到zk上。数据存储使…

我们在《360度测试：KAFKA会丢数据么？其高可用是否满足需求？》这篇文章中，详细说明了KAFKA是否适合用在业务系统中。但有些朋友，还不知道KAFKA为何物，以及它为何存在。这在工作和面试中是比较吃亏的，因为不…

Elasticsearch作为当前主流的全文检索引擎，除了强大的全文检索能力和高扩展性之外，对多种数据源的兼容能力也是其成功的秘诀之一。而Elasticsearch强大的数据源兼容能力，主要来源于其核心组件之一的Logstash, L…

前言 在上文 设计一个百万级的消息推送系统 中提到消息流转采用的是 Kafka 作为中间件。 其中有朋友咨询在大量消息的情况下 Kakfa 是如何保证消息的高效及一致性呢？ 正好以这个问题结合 Kakfa 的源码讨论下如何…

序 本文主要展示一下如何使用reactor-kafka maven {代码…} 准备 启动zookeeper {代码…} 启动kafka {代码…} 创建topic {代码…} 实例 producer {代码…} consumer {代码…} 小结 reactor-kafka对kafka的a…