直接去 D:\Tool\zookeeper-3.4.14\bin， 运行 zkServer.cmd. kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1

deepin发行版的处理方法是 在 ~/.bashrc 脚本中 增加一句 source /etc/profile

Kafka是一个消息系统，原本开发自 LinkedIn，用作 LinkedIn 的活动流和运营数据处理管道的基础。现在它已被多家不同类型的公司 作为多种类型的数据管道和消息系统使用。支持 Kafka Server 间的消息分区，及分布式消费，同时保证每个

创建生产者时，可以指定retries参数，如果向broker发送消息时抛出异常，并且异常是可重试异常RetriableException，那么此时就会按照指定的次数进行重试。后台存在一个IOThread，会一直扫描这块内存，也就是这个线程真正的把消息发给b

batch 发送，batch 存储，batch 拉取。kafka-consumer-groups.bat --bootstrap-server localhost:9092 --reset-offsets --execute --group zhang-w

传统消息中间件，一次只发送单挑消息；kafka，一次发送多条消息，微批处理。日志格式，数据压缩，snappy，

一个好的程序员，应该能设计出好的架构，而好的架构的各个系统之间往往是低耦合的，而消息队列，正是一个解耦的神器。 消息队列，也称消息中间件，主要优点是解耦、削峰、异步扩展性；并且kafka还能保证消息是顺序消费；同时kafka天生的持久化和多副本机制，让数据

保证kafka高吞吐量的另外一大利器就是消息压缩。就像上图中的压缩饼干。压缩即空间换时间，通过空间的压缩带来速度的提升，即通过少量的cpu消耗来减少磁盘和网络传输的io。kafka不会直接操作单条消息，而是直接操作一个消息集合。1, 抽取了消息的公共部分放

Kafka的消息是保存或缓存在磁盘上的，一般认为在磁盘上读写数据是会降低性能的，因为寻址会比较消耗时间，但是实际上，Kafka的特性之一就是高吞吐率。即使是普通的服务器，Kafka也可以轻松支持每秒百万级的写入请求，超过了大部分的消息中间件，这种特性也使得

日志是每个系统最为头疼的地方，杂乱，还多，没有还不行，想管理好的话，得经得起考验，要解决的问题总结如下：。Kafka主要是解决大量日志的处理的分布式发布订阅消息系统，拥有高吞吐量，相比Redis而言，可能存在数据丢失的情况，速度更快，仅支持topic模式，

Apache Kafka是一个开源消息系统，由Scala写成。Kafka最初是由LinkedIn开发，并于2011年初开源。2012年10月从Apache Incubator毕业。该项目的目标是为处理实时数据提供一个统一、高通量、低等待的平台。Kafka是

```启动es

Kafka把topic中一个parition大文件分成多个小文件段，通过多个小文件段，就容易定期清除或删除已经消费完文件，减少磁盘占用。通过索引信息可以快速定位message和确定response的最大大小。通过index元数据全部映射到memory，可以

　　创建队列的时候，replication-factor只能是1个，因为是单节点，而partitions分区可以是1个或者2个都可以，测试环境建议是1个即可。　　此时，命令行会进入运行状态，界面就卡住不动了，然后再新建一个窗口，进入kafka目录，继续创建

In our previous blog onA Case for Mirromaker 2,we had discussed how enterprises rely on Apache Kafka as an essential component o

使用文本编辑工具编辑zoo，将文件下的dataDir目录修改为如下。在系统变量下，新建，命名为ZOOKEEPER_HOME,添加path，双击path，点击新建，添加zookeeper的bin目录。进入zookeeper的bin目录，按住shift，点击右

项目中经常有需求不是消费kafka队列全部的数据，取区间数据

很多人对比kafka和AMQP的时候，都会强调kafka会丢数据，感觉好像只要用kafka就会丢数据一样，从而排斥使用kafka，亦或者在使用的过程中，发现数据丢失就认定罪魁祸首是kafka，好像丢数据就是使用kafka的代价。悄悄的鄙视一下这些伪程序猿。

创建topic话题bin/kafka-topics.sh --create --topicnews（话题名） --bootstrap-server 192.168.79.137:9092 -partitions（分区） 3 -replication-fac

//创建一个topic,名称为test_kafka，partitions为2个，replication有3个，topic的name为test2:. kafka-topics --zookeeper zk1:2181,zk2:2181,zk3:2181 --