《kafka权威指南》
使用场景
1、活动跟踪 前端应用与用户的交互记录,pv、uv、点击量等
2、传递消息 用来实现消息通知功能
3、度量指标和日志记录 系统日志以及度量指标的收集
4、提交日志 作为分布式系统的日志缓冲区,方便日志收集处理
5、流处理 用哦过户可以飙血消息那应用程序来操作kafka消息,比如计算度量指标,为其他应用程序有效的处理消息分区,或者对来自多个数据源的消息进行转换。
kafka优化
1、客户端配额限制
a.直接在zookeeper的配置文件里面添加配置 ref。
b.此外,我们还可以通过kafka-topics.sh脚本动态修改客户端的配额 。 比如,下面的命令设置了默
认用户、指定编号等于client!的客户端配额信息是生产者速率的配额为 I KB/s ,消费者速率的配额为
2 KB/s:
$ bi.n/kafka -confi.gs .sh --zookeepe「 localhost:2181 --alte「-- add-confi.g \
’ P 「。duce 「_ byte_「 ate=1024,consul'le 「_ byte_「 ate=2048 '飞
10 . 1 ’ 客户端配额 687
-- enti.ty - type use「s - -enti.ty -default \
--enti.ty-type cli.ents --enti.ty - nal'le cli.entl
表 JO-I 列举了针对用户和客户端进行配额控制的多种组合方式 。 管理员通过kafka-configs .sh命令
修改配额配置,可以动态修改ZK节点的数据。 所有的服务端代理节点会读取ZK中的配置信息,我们
不需要重启整个集群,修改后的配额配置也能立即生效。
Research of kafka(a streaming message system)
1.quick starthttp://colobu.com/2014/08/06/kafka-quickstart/
2.cluster boot
http://blog.csdn.net/dhtx_wzgl/article/details/46892231
http://www.cnblogs.com/Orgliny/p/5526159.html
3.kafka java consumer
http://www.orchome.com/451
4.kafka java producer
http://orchome.com/303