Kafka 0.10 Producer网络流程简述
1.Producer 网络请求 1.1 Producer Client角度 KafkaProducer主要靠Sender来发送数据给Broker。 Sender: 该线程handles the sending of produce requests to the Kafka ...
原文：Kafka 0.10 KafkaConsumer流程简述
ConsumerConfig.scala 储存Consumer的配置 按照我的理解， . 的Kafka没有专门的SimpleConsumer，仍然是沿用 . 版本的。 .从poll开始 消费的规则如下： 一个partition只能被同一个ConsumersGroup的一个线程所消费. 线程数小于partition数，某些线程会消费多个partition. 线程数等于partition数，一个线程正 ...
2017-02-07 09:34 0 9670 推荐指数：
相关推荐
Kafka 0.10 Metadata的补充
什么是Metadata？ Topic/Partion与broker的映射关系：每一个Topic的每一个Partion的Leader、Follower的信息。 它存在哪里？持久化在Zookeeper中 ...
Kafka 0.10 Coordinator概述
由Kafka内置实现了失败检测和Rebalance(ZKRebalancerListener)，但是它存在羊群效应和脑裂的问题，客户端代码实现低级API也不能解决这个问题。如果将失败探测和Rebalance的逻辑放到一个高可用的中心Coordinator，这两个问题即可解决。同时还可大大减少 ...
【Kafka源码】KafkaConsumer
目录 一、偏移量和消费者位置Offsets And Consumer position 1.1 TopicPartition 1.2 committed ...
Kafka 0.10问题点滴
Kafka 0.8.2.x 2.For Kafka 0.9.x.x and 0.10.0.0 ...
Kafka 0.10 DelayedTaskQueue的用法和实现
DelayedTaskQueue 是在ConsumerNetworkClient类中使用，是Kafka自己实现的一个很重要的数据结构。 官方解释：延时队列，Tracks a set of tasks to be executed after a delay. 我的理解 ...
使用Python操作Kafka：KafkaProducer、KafkaConsumer
其实很早就是用kafka了，但是一直都用的非常简单，最近写一个小功能的时候又要用到kafka，于是就花点时间好好看了一下网上关于kafka的一些文档和博客，发现了一个很不错的博客，做个记录和分享。 原文链接： https://www.cnblogs.com/rexcheny/articles ...
Kafka0.10的新特性一览
原文链接:http://kane-xie.iteye.com/blog/2301197 2016年5月Confluent官方宣布Apache Kafka 0.10正式发布。该版本包含了很多新功能和优化，这里列出比较重要的几项： Streams 如果你有这样的需求，从Kafka拉取数据 ...