可能是现在能找到的最好的可视化的Kafka管理工具, 感谢Yahoo-我人生中打开的一个网站-的开源;
使用Kafka Manager, 基本上之前需要运行Kafka相应命令行工具的工作现在都可以可视化的完成:
创建...Partition数量等等配置;
管理Topic, 包括Reassign Partitions, Preferred Replica Election等等;
消费情况查看, 支持offset保存到zk和broker...framework: Kafka-Mananger本质上是个Web应用, 因此使用play framework的MVC架构实现;
AKKA: 用于构建高并发、分布式和容错的应用....实现:
其实kafka manager的代码还是很清晰易阅读的, 如果熟悉scala和play的话应该没有难度. 不同本人也是现学现用, 好惭愧~~~....PartitionOffsetsCapture], 每个topic一个Future, 使用Google的LoadingCache来存储这些future, 利用LoadingCache的超时淘汰机制来周期性的创建新的