Metamorphosis
Metamorphosis copied to clipboard
A high available,high performance distributed messaging system.
锁的粒度有点大啊。 用这个实现会不会更好?http://code.google.com/p/concurrentlinkedhashmap
用户可指定备份间隔。
异步复制,在运行一段时间后出现offset错乱的问题,需测试重现下。
See https://cwiki.apache.org/confluence/display/KAFKA/Central+Consumer+Coordination
现在的group commit实现是利用单独的一个线程,考虑在写的线程上做group commit,减少线程数。
为协议添加版本信息,为未来添加更多协议做准备,做好向前兼容。
- 用户认证; - 类似rabbitmq的vhost的概念 - 不同用户拥有不同vhost的访问权限; - 可通过API新增vhost; - ...