加载中
如何保证向kafka中写入数据时,数据不会丢失

1、Kafka写入数据丢失问题 什么情况下Kafka中写入数据会丢失呢? 其实也很简单,大家都知道写入数据都是往某个Partition的Leader写入的,然后那个Partition的Follower会从Leader同步数据。但...

05/12 12:09
512
Zero-copy

首先需要知道应用场景: 适用于静态资源从磁盘到网络的发送(中间不对资源进行改变),这在web server提供的功能中很常见,一个例子是:保存在磁盘上的一张图片应某个网络请求被从磁盘中取出...

2019/01/11 17:03
242
kafka tools中的管理工具

Kafka内部提供了许多管理脚本,这些脚本都放在$KAFKA_HOME/bin目录下,而这些类的实现都是放在源码的kafka/core/src/main/scala/kafka/tools/路径下。 Consumer Offset Checker Consumer Off...

2017/06/28 16:51
3.9K
kafka监控之kafka-run-class.sh

kafka自带了很多工具类,在源码kafka.tools里可以看到: 这些类该如何使用呢,kafka的设计者早就为我们考虑到了,在${KAFKA_HOME}/bin下,有很多的脚本,其中有一个kafka-run-class.sh,通过...

2017/03/17 19:22
8.3K
kafka在zookeeper里的结构

kafka在zookeeper里的结构图: 1.topic注册信息 /brokers/topics/[topic] : 存储某个topic的partitions所有分配信息 Schema: { "version": "版本编号目前固定为数字1", "partitions...

2017/03/17 18:56
121
kafka分区策略

public class kafkaProducer extends Thread{ private String topic; public kafkaProducer(String topic){ super(); this.topic = topic; } ...

2017/03/14 10:16
360
kafka彻底删除topic

如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况: 如果当前topic没有使用过即没有传输过信息:可以彻底删除 如果当前topic有使用过即有过传输过信息:并没有真正删除topic只...

2017/03/14 09:46
92
kafka常用命令

以下是kafka常用命令行总结: 1.查看topic的详细信息 ./kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic testKJ1 2、为topic增加副本 ./kafka-reassign-partitions.sh --zoo...

2017/03/13 20:04
134
kafka参数配置详解

kafka参数配置详解

2016/01/28 17:45
5.7K
kafka java编程

kafka java编程

2016/01/25 13:18
1K
kafka集群搭建

kafka集群搭建

2016/01/22 12:52
1.5K
kafka存储机制

kafka存储机制

2016/01/21 17:48
392
kafka入门

kafka入门

2016/01/21 17:11
322

没有更多内容

加载失败,请刷新页面

没有更多内容

返回顶部
顶部