Kafka的Simple Consumer并不简单。相反的，它是直接在对Kafka的partition和offset进行操作，是一种比较接近底层的方案。
为什么要使用Simple Consumer
使用SimpleConsumer最主要的原因是想在消费消息时获取更大的权限。比如说要做下面这些事情：
- 多次读取同一条消息；
- 在一个处理过程中，只消费topic中partiti
分类目录归档：Kafka
Kafka Producer程序示例
这次是要写一个Producer示例程序。使用的kafka版本是0.8.2。开发语言是java。
程序主体是一个Producer类。这个Producer类主要是用来为指定的topic创建消息。
首先需要引入一些支持类：
|
1 2 3 |
import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMes |
kafka简介
简介
kafka是一个分布式的、可分区的、可复制的日志提交服务。它提供了消息传递的功能，但是有着独特的设计。
首先，先了解一些基础概念：
- Kafka将消息源的分类称为topic；
- 向Kafka的topic发送消息的进程被称为producer；
- 订阅并消费消息的进程被称为consumer；
- Kafka运行在由一个或多个服务组成的集群上，其中的每个服务被称为broker。
从…