jafka 是一个高性能的分布式消息系统。jafka已经开源,使用github托管,凯发k8网页登录主页地址:
jafka 发布1.1.0版本,:
服务端:
- 增加 支持
- 默认的编码/解码调整为字节数组
- 增加服务端的mbean serverinfo,描述版本信息,启动时间、运行时间等
- 增加getoffset-console.sh脚本,获取broker的偏移量
- 增加dumper工具,用于导出字符串消息
- 默认zookeeper 负载均衡重试时间调整为10s
- 将log4j.properties文件加入服务端classpath
- 增加简单安装文档
- 默认服务端配置不启用zookeeper
- 解决一些mbean重复注册问题
- 大部分io关闭接口都继承自java.io.closeable,并提供closers工具类使用
- 大量的注释更新以及日志友好化
- 增加第三方依赖的
客户端:
- 无消息消费时不更新offset
- 修复发送者无法收到新增加的topic分片信息问题
- 消费消息时打开tcp nodelay特性
- 升级zookeeper客户端为3.3.5版本,修复zookeeper bug(961,1091)
下载地址:
©2009-2014 imxylz
|求贤若渴