Kafka 学习笔记(三)之Java Consumer客户端
2015-07-11 03:03
561 查看
写了producer,这篇我们来看看consumer。
理论上讲,Kafka的consumer有high level 和low level的两种,这点和producer一样。High level 的不用管offset 和load balancing,都是kafka写好了的,用high level的API呢,control的权限就小一些。 但是如果我们要动offset,想看以前的message,就需要更大的权限,这样需要low level的,作为tradeoff,我们就要考虑更多的东西。更详细的官网上有介绍。
由于我也是初学的菜鸟,我们从简单好用的High level学起。如果以后用到low level的,会再写出来。
用到的代码还是上一篇的github上写好的代码。文件夹里有consumer的java file,做的是moving average,链接如下
https://github.com/gwenshap/kafka-examples/blob/master/SimpleMovingAvg/src/main/java/com/shapira/examples/zkconsumer/simplemovingavg/SimpleMovingAvgZkConsumer.java
首先打开consumer
Consumer 开启用的script
./run_params.sh localhost:2181 avg test1 10 120000
Producer开启,用我们上一篇介绍的producer来产生data
命令和上一篇的一样
然后producer端产生data并送到broker,consumer端收到data以后,做移动平均。我们这时看consumer的窗口:
打印出了平均值。很好。consumer works!
前几篇都是写的java客户端,下一篇我们来介绍一些python客户端。
To be continued!
理论上讲,Kafka的consumer有high level 和low level的两种,这点和producer一样。High level 的不用管offset 和load balancing,都是kafka写好了的,用high level的API呢,control的权限就小一些。 但是如果我们要动offset,想看以前的message,就需要更大的权限,这样需要low level的,作为tradeoff,我们就要考虑更多的东西。更详细的官网上有介绍。
由于我也是初学的菜鸟,我们从简单好用的High level学起。如果以后用到low level的,会再写出来。
用到的代码还是上一篇的github上写好的代码。文件夹里有consumer的java file,做的是moving average,链接如下
https://github.com/gwenshap/kafka-examples/blob/master/SimpleMovingAvg/src/main/java/com/shapira/examples/zkconsumer/simplemovingavg/SimpleMovingAvgZkConsumer.java
首先打开consumer
Consumer 开启用的script
./run_params.sh localhost:2181 avg test1 10 120000
Producer开启,用我们上一篇介绍的producer来产生data
命令和上一篇的一样
然后producer端产生data并送到broker,consumer端收到data以后,做移动平均。我们这时看consumer的窗口:
打印出了平均值。很好。consumer works!
前几篇都是写的java客户端,下一篇我们来介绍一些python客户端。
To be continued!
相关文章推荐
- java初级笔记_Socket
- MAC JAVA 环境变量那些事
- Java设计模式之备忘录模式
- JAVA字符串的比较
- Eclipse中Git的使用
- windows安装java/jdk
- Java自学笔记(Java自学教程/带示意图) - 罗函
- javah、javap的用法
- [Android--Tool]开发前eclipse preference的一些简单设置
- Eclipse 快捷键
- [Com]Java中的串口编程
- [JDK]什么是JDK
- [Keyword]Java语言中的关键字及其说明
- 三步制作自定义图标的微博第三方登录
- java初级笔记_反射
- [Debug]Windows下命令行编译java程序,文件组织/问题/解决
- java数组初始化
- [JDK]jdk1.7.0下载安装及简单环境配置(jdk1.8.0同样方式)
- Eclipse打开出错:Java wa started but returned exit code=13
- 下拉列表框Spinner-采用javabean作为Adapter元素