bboss kafka组件使用介绍
bboss kafka组件使用介绍
本文使用的实例对应的gradle源码工程git访问地址：
http://git.oschina.net/bboss/bestpractice
testkafka子工程地址
http://git.
kafka web console安装
貌似很多小伙伴都不能成功打包，共享下之前打包的文件：
http://pan.baidu.com/s/1sjkE37J
========
kafka自己居然没有还一个Web管理界面。
Streamworks，基于扩展FlinkSQL实现流计算的源表导入、维表关联与结果表导出
Streamworks，袋鼠云基于SQL的流计算开发平台，其通过扩展FlinkSQL，实现FlinkSQL与界面化配置映射结合的方式，完成Kafka源数据的读入，并支持流数据与Mysql/Oracle/MongDB等数据源进行维表关联，将最终结果数据导出至Hbase/ES/Greenplum/Oracle/OceanBase等目标数据库，进行一站式的流数据开发。
【原创】如何写一个框架：模式
模式
接下来去聊一聊框架设计中的一些常见设计模式，这和传统的一些设计模式不同（之前写过 无废话C#设计模式系列文章，有兴趣的读者可以去看一下），这里聊的一些设计模式是比较高层的粗粒度的架构设计模式，主要是用于之前说的构建框架的龙骨，使得框架中的几百个类型可以有结构有条理组织在一起，在这些模式之中你完全可以再去使用各种Gof设计模式，这是不冲突的。
Pulsar与Kafka消费模型对比
kafka
kafka 属于 Stream 的消费模型，为了支持多 partition 的消费关系，引入了 consumer group 的概念，同时支持在消费端动态的 reblance 操作，当多个 Consumer 订阅了同一个 Topic 时，会根据分区策略进行消费者订阅分区的重分配。
跟我学Kafka之NIO通信机制
很久没有做技术方面的分享了，今天闲来有空写一篇关于Kafka通信方面的文章与大家共同学习。
一、Kafka通信机制的整体结构
74EACA88-8B9D-45F8-B7BF-202D658205A9.png
这个图采用的就是我们之前提到的SEDA多线程模型，链接如下：http://www.jianshu.com/p/e184fdc0ade4
1、对于broker来说，客户端连接数量有限，不会频繁新建大量连接。
Kafka Tools
参考，
https://cwiki.apache.org/confluence/display/KAFKA/System+Tools
https://cwiki.apache.