一、功能管理多个kafka集群便捷的检查kafka集群状态(topics,brokers,备份分布情况,分区分布情况)选择你要运行的副本基于当前分区状况进行可以选择topic配置并创建topic(0.8.1.1和0.8.2的配置不同)删除topic(只支持0.8.2以上的版本并且要在broker配置中设置delete.topic.enable=……继续阅读 » 开心洋葱 8年前 (2018-07-08) 2124浏览 0评论2854个赞
类似于数据库的连接池(+) (#)事件处理线程说明如果事件处理的逻辑能迅速完成，并且不会发起新的IO请求，比如只是在内存中记个标识，则直接在IO线程上处理更快，因为减少了线程池调度。但如果事件处理逻辑较慢，或者需要发起新的IO请求，比如需要查询数据库，则必须派发到线程池，否则IO线程阻塞，将导致不能接收其它请求。如果用IO线程处……继续阅读 » 开心洋葱 8年前 (2018-07-07) 2468浏览 0评论2685个赞
