Elasticsearch是什么 Elaticsearch简称为ES,是一个开源的可扩展的分布式的全 […]
消费发送 生产者向消息队列里写入消息,不同的业务场景需要生产者采用不同的写入策略。比如同步发送、 异 […]
RocketMQ是阿里巴巴中间件团队自研的一款高性能、高吞吐量、低延迟、高可用、高可靠(具备 金融级 […]
集群应用场景 消息传递 Kafka可以很好地替代传统邮件代理。消息代理的使用有多种原因(将处理与数据 […]
延时队列 两个follower副本都已经拉取到了leader副本的最新位置,此时又向leader副本 […]
事务 事务场景 如producer发的多条消息组成一个事务这些消息需要对consumer同时可见或者 […]
日志存储概述 Kafka 消息是以主题为单位进行归类,各个主题之间是彼此独立的,互不影响。 每个主题 […]
副本机制 Kafka在一定数量的服务器上对主题分区进行复制。 当集群中的一个broker宕机后系统可 […]
管理 使用kafka-topics.sh脚本: 主题中可以使用的参数定义: 创建主题 查看主题 修改 […]
概念入门 消费者、消费组 消费者从订阅的主题消费消息,消费消息的偏移量保存在Kafka的名字是 __ […]