作者回复: 对于我们这节课的作业,实现这个Proxy你不需要自己写一个MQ的客户端,完全可以使用已有的客户端。
比如,你的Broker是RocketMQ,Proxy可以集成RocketMQ的客户端与Broker通信就可以了。
作者回复: 对认真完成作业的同学点个赞!
对于消费时序图,Metadata中的数据结构是什么样呢?希望同学能细化一下。
作者回复: 关于Kafka集群能支持多少个topic,这个取决的因素很多,集群的节点数量,集群规模大小,zk的配置等等,有个关于这个问题的测试,你可以看一下:https://blogs.apache.org/kafka/entry/apache-kafka-supports-more-partitions
zk的节点数量,一般最多配置成7个,observer的场景实际上并不常用,只有一种场景才需要用到Observer:你有海量的zk客户端,大部分和zk的交互都是读操作,这种情况下才需要用Observer来支撑海量的客户端数量。
增加ZK的节点数量并不能提升ZK的性能,写性能反而会降低,读性能也不会随着节点数量有提升,但是,节点数越多,可以支撑更多的并发读,只有这块儿性能会有提升。