Kafka是一个分布式的、基于发布/订阅的消息系统。主要设计目标如下:提供时间复杂度为O(1)的消息持久化能力,即使对于TB级别以上的数据,也能保证时间复杂度恒定的访问性能。高吞吐量。即使在非常便宜的商用机器上,单台机器也可以支持每秒超过100K条消息的传输。支持KafkaServer之间的消息分区和分布式消费,同时保证消息在各个Partition中的顺序传输。支持离线数据处理和实时数据处理。支持在线横向扩展。想查看Topic中的消息却找不到软件,想查看或更新Broker、Topic配置,想监控Broker服务器状态?试试下面的KafkaGUI工具——KafkaAssistant官网地址:http://www.redisant.cn/ka连接到Kafka集群,进入Bootstrapserver和Post进行连接,支持各种认证协议Dashboard通过上dashboard点击按钮打开实时监控界面,可以查看请求处理器空闲率、出入字节数、入消息量等。生成拓扑图Topology.describe()将返回的字符串一键转换为拓扑图查看主题选择主题选项卡可以列出当前集群下的所有主题。右侧可以查看集群消息(支持按时间过滤)、分区、配置修改查看发送的消息支持各种类型的压缩,ack类型,也可以定时发送Broker配置查看修改更多功能会就不一一介绍了。
