首页 > TAG信息列表 > kafak

Kafak入门

1.       kafka介绍   1.1.       主要功能 根据官网的介绍，ApacheKafka®是一个分布式流媒体平台，它主要有3种功能： 　　1：It lets you publish and subscribe to streams of records.发布和订阅消息流，这个功能类似于消息队列，这也是kafka归类为消息队列框架的原因 　

如何让Kafak尽可能不丢失消息

Kafka 只对“已提交”的消息（committed message）做有限度的持久化保证 已提交，commit，若干个（可用配置设置） Broker 成功地接收到一条消息并写入到日志文件后，它们会告诉生产者程序这条消息已成功提交。 有限度，假如你的消息保存在 N 个 Kafka Broker 上，那么这个前提条件就是这 N 个 Broke

kafak日志自动删除

#!/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集群

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、 打开

Kafak探究之路- 内部结构小结

1.框架与工作流           2 内部结构 kafka的每个主题分区的数据在 first-0（主题名-分区号）文件夹下，保存 n组xxx.log文件与xxx.index文件。log文件存发送消息的元数据，每个大小默认为1G,index为log的索引存这些消息的序号与起始地址。index每个索引大小一样，这样硬件寻址的时