ack应答机制 有三个值： 0：producer不需要确认消息，直接发送消息给leader，有没有收到消息，producer不管； 上图中去掉5、6步；速度块，安全性最低（当broker故障，会 丢失数据 ）。 1：producer发送消息，确保leader写入成功，followers不管；上图中， ...
分类：
其他好文 时间：
2020-01-13 12:54:21
阅读次数：
496
kafka的bin目录下有很多脚本，其中kafka-console-producer.sh是生产者脚本、kafka-console-consumer.sh是消费者脚本，下面用这两个脚本进行模拟发送消息和接收消息。在前面的3篇中已经介绍了kafka的配置。按照步骤启动zookeeper和kafka。 ...
分类：
其他好文 时间：
2020-01-12 22:18:30
阅读次数：
129
1.消息发送机制 Kafka的ack机制。 当producer向leader发送数据时，可以通过request.required.acks参数来设置数据可靠性的级别： 1（默认）：这意味着producer在ISR中的leader已成功收到的数据并得到确认后发送下一条message。如果leader宕 ...
分类：
其他好文 时间：
2020-01-11 20:15:43
阅读次数：
92
一、安装 kafka可以通过官网下载：https://kafka.apache.org/downloads kafka根据Scala版本不同，又分为多个版本，我不需要使用Scala，所以就下载官方推荐版本kafka_2.12-2.4.0.tgz。 使用tar -xzvf kafka_2.12-2.4 ...
分类：
其他好文 时间：
2020-01-07 00:32:37
阅读次数：
159
点击查看折叠代码块 / 普通消息生产者 / public class Producer { public static void main(String[] args) throws Exception { // 创建一个消息发送入口对象，主要用于消息发送，指定生产者组 DefaultMQProdu ...
分类：
其他好文 时间：
2020-01-06 14:55:32
阅读次数：
67
温馨提示：本文基于 Kafka 2.2.1 版本。本文主要是以源码的手段一步一步探究消息发送流程，如果对源码不感兴趣，可以直接跳到文末查看消息发送流程图与消息发送本地缓存存储结构。 从上文 "初识 Kafka Producer 生产者" ，可以通过 KafkaProducer 的 send 方法发送 ...
分类：
其他好文 时间：
2020-01-05 18:32:04
阅读次数：
107
温馨提示：整个 Kafka Client 专栏基于 kafka 2.3.0 版本。 @ "TOC" 1、KafkaProducer 概述 根据 KafkaProducer 类上的注释上来看 KafkaProducer 具有如下特征： KafkaProducer 是线程安全的，可以被多个线程交叉使用。 ...
分类：
其他好文 时间：
2019-12-31 21:31:49
阅读次数：
72
# 架构设计 1 技术架构 RocketMQ架构上主要分为四部分，如上图所示: Producer：消息发布的角色，支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递，投递的过程支持快速失败并且低延迟。 Consumer：消息消费的角色，支持分布式 ...
分类：
其他好文 时间：
2019-12-24 14:04:48
阅读次数：
75
# 基本概念 ## 1 消息模型（Message Model）RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Br ...
分类：
其他好文 时间：
2019-12-24 13:23:29
阅读次数：
53
队列： # 生产者 def producer(name, food, q): for i in range(20): time.sleep(random.random()) f = "%s 制作了的第%s个%s" % (name, i, food) print(f) # 将数据放入队列中 q.put ...
分类：
系统相关 时间：
2019-12-18 09:27:08
阅读次数：
105
