rocketmq 4.X 扩容思路
开篇
周末抽空去参加了rocketmq杭州站的Meetup，虽然之前阅读过rocketmq的一些源码，不过本身不是专业运维消息中间件的所以相对的运维经验不足，在跟公司的中间件普大神聊天的时候提到了一些问题，刚好趁这次机会一起请教了。
可视化与领域驱动设计
从DDD的角度，领域逻辑的分析可以运用战略方法Bounded Context。问题是：如何获得Bounded Context ？
初探Java设计模式3：行为型模式（策略，观察者等）
转自https://javadoop.com/post/design-pattern
行为型模式
策略模式
观察者模式
责任链模式
模板方法模式
状态模式
行为型模式总结
本系列文章将整理到我在GitHub上的《Java面试指南》仓库，更多精彩内容请到我的仓库里查看
https://github.
Apache NiFi之Kafka流数据到HBase
一.说明
在大数据平台的业务场景中，处理实时kafka数据流数据，以成为必要的能力；此篇将尝试通过Apache NiFi来接入Kafka数据然后处理后存储之HBase
二.开拔
Ⅰ).配置ConsumeKafka_0_10
测试使用了kafka0.
Kafka压缩
在某些情况下，整个应用的瓶颈不在于CPU或者磁盘，而是受网络带宽的影响。当然你可以选择在业务代码中对每一条消息做压缩处理，之后再发送到kafka中，之后业务消费端再进行解压处理，这种方式对应消息的压缩效率是非常低。