13页，消费者，三个消费者消费同一个分区，一个分区只能被一个消费者消费了
13页，三个消费者消费同一个分区，不是一个分区只能被一个消费者消费么
1.1中消费者会验证分区数量，我有个topic32个分区。其中一个是从metadata获取的是32个，另一个获取的时候只有23个，看不懂是哪里获取的。源码在InternalTopicManager,validateTopicPartitions方法。望请赐教，万分感谢。
小弟在此书获益良多，太感谢了，不过小弟有一些疑惑kafka集群中多个broker会有一个在zk的/controller注册临时节点成为kafka controller，其余为follower并watch这个/controller的子节点。当通过命令创建topic，或auto create topic的时候，会在zk的/brokers/topics/创建topic持久节点，然后kafka controller所在broker的相关类partitionSateMachine的topicChangeLisenter会监测到/brokers/topics/子节点的变化，进而创建此topic对应的目录和文件以及内存中相关元数据。如果kafka controller在监听到topic新增并准备后续处理的时候，kafka controller宕机，其余follower之一在zk重新注册成为kafka controller，并添加新的topicChangeLisener，新kafka controller已经无法处理上一届kafka controller创建topic相关文件等后续操作了？其他lisener也有相同的问题？
源码编译的时候出现无法加载主类怎么解决呢
遇到同样的问题，请作者或者其他高手解答
13页，消费者，三个消费者消费同一个分区，一个分区只能被一个消费者消费了
13页，三个消费者消费同一个分区，不是一个分区只能被一个消费者消费么
1.1中消费者会验证分区数量，我有个topic32个分区。其中一个是从metadata获取的是32个，另一个获取的时候只有23个，看不懂是哪里获取的。源码在InternalTopicManager,validateTopicPartitions方法。望请赐教，万分感谢。
小弟在此书获益良多，太感谢了，不过小弟有一些疑惑
kafka集群中多个broker会有一个在zk的/controller注册临时节点成为kafka controller，其余为follower并watch这个/controller的子节点。当通过命令创建topic，或auto create topic的时候，会在zk的/brokers/topics/创建topic持久节点，然后kafka controller所在broker的相关类partitionSateMachine的topicChangeLisenter会监测到/brokers/topics/子节点的变化，进而创建此topic对应的目录和文件以及内存中相关元数据。如果kafka controller在监听到topic新增并准备后续处理的时候，kafka controller宕机，其余follower之一在zk重新注册成为kafka controller，并添加新的topicChangeLisener，新kafka controller已经无法处理上一届kafka controller创建topic相关文件等后续操作了？其他lisener也有相同的问题？
源码编译的时候出现无法加载主类怎么解决呢
