集群应用场景 消息传递 Kafka可以很好地替代传统邮件代理。消息代理的使用有多种原因(将处理与数据 […]
延时队列 两个follower副本都已经拉取到了leader副本的最新位置,此时又向leader副本 […]
事务 事务场景 如producer发的多条消息组成一个事务这些消息需要对consumer同时可见或者 […]
日志存储概述 Kafka 消息是以主题为单位进行归类,各个主题之间是彼此独立的,互不影响。 每个主题 […]
副本机制 Kafka在一定数量的服务器上对主题分区进行复制。 当集群中的一个broker宕机后系统可 […]
管理 使用kafka-topics.sh脚本: 主题中可以使用的参数定义: 创建主题 查看主题 修改 […]
概念入门 消费者、消费组 消费者从订阅的主题消费消息,消费消息的偏移量保存在Kafka的名字是 __ […]
消息发送 数据生产流程解析 Producer创建时,会创建一个Sender线程并设置为守护线程。 生 […]
概念和基本架构 Kafka介绍 Kafka是最初由Linkedin公司开发,是一个分布式、分区的、多 […]