本文分析的Kafka代码为kafka-0.8.2.1。另外，由于Kafka目前提供了两套Producer代码，一套是Scala版的旧版本；一套是Java版的新版本。虽然Kafka社区极力推荐大家使用Java版本的producer，但目前很多已有的程序还是调用了Scala版的API。今天我们就分析 ...

既然Kafka使用Scala写的，最近也在慢慢学习Scala的语法，虽然还比较生疏，但是还是想尝试下用Scala实现Producer和Consumer，并且用HashPartitioner实现消息根据key路由到指定的partition。 Producer: import ...

brokers和消费者使用zk来获取状态信息和追踪消息坐标。 每一个partition是一个有序的，不可变的消息序列。 只有当partition里面的file置换到磁盘文件以后，才开放给消费者来消费。 ...

kerberos简单介绍 kerberos这一名词来源于希腊神话“三个头的狗---地狱之门守护者”后来沿用作为安全认证的概念，该系统设计上 采用客户端/服务器结构与DES(Data Encrypt ...

一.前言 　　任何消息队列都是万变不离其宗都是3部分，消息生产者（Producer）、消息消费者（Consumer）和服务载体（在Kafka中用Broker指代）。那么本篇主要讲解Producer端，会有适当的图解帮助理解底层原理。 　 一.开发应用 　　首先介绍一下开发应用，如何构建一个 ...

粘贴一下这个配置，与我自己的程序做对比，看看能不能完善我的异步带代码； ----------------------------------------- 详解Kafka生产者 ...

一、Kafka设计原理参考： http://blog.csdn.net/suifeng3051/article/details/48053965?locationNum=2 http://www.cnblogs.com/metoy/p/4452124.html 二、常见问题 ...

　　在上一篇kafka入门的基础之上，本篇主要介绍Kafka的生产者和消费者。 Kafka 生产者　　 　　kafka Producer发布消息记录到Kakfa集群。生产者是线程安全的，可以在多个线程之间共享生产者实例。一个简单的例子，使用producer发送一个有序的key/value(键值 ...