1. kafka介绍 1.1. 主要功能 根据官网的介绍，ApacheKafka®是一个分布式流媒体平台，它主要有3种功能： 1：It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队列框架的原因
Kafka 只对“已提交”的消息（committed message）做有限度的持久化保证 已提交，commit，若干个（可用配置设置） Broker 成功地接收到一条消息并写入到日志文件后，它们会告诉生产者程序这条消息已成功提交。 有限度，假如你的消息保存在 N 个 Kafka Broker 上，那么这个前提条件就是这 N 个 Broke
#!/usr/bin/env bash RETAIN_FILES_NUM=72 RETAIN_FILES_TIME=72 RETAIN_FILE_MB=1024 function retain_files_num() { echo "" } function retain_files_date(){ for file_name in $* ; do FILE_NAME=${file_name} # 确认给定时间之前的时间
linux-centos7搭建kafak集群 下载kafka，这里我们使用2.6.0版本 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.7.0/kafka_2.13-2.7.0.tgz 解压 tar -zxvf kafka_2.13-2.7.0.tgz 单节点zookeeper和单节点kafka启动 修改配置文件 vim ./config/server.properties、 打开
1.框架与工作流 2 内部结构 kafka的每个主题分区的数据在 first-0（主题名-分区号）文件夹下，保存 n组xxx.log文件与xxx.index文件。log文件存发送消息的元数据，每个大小默认为1G,index为log的索引存这些消息的序号与起始地址。index每个索引大小一样，这样硬件寻址的时
