芥为之舟

感谢，已经更新了，多找找问题哈~！

Once assigned, you can call poll in a loop, just as in the preceding examples to consume records. The group that the consumer specifies is still used for committing offsets, but now the set of partitions will only change with another call to assign. Manual partition assignment does not use group coordination, so consumer failures will not cause assigned partitions to be rebalanced. Each consumer acts independently even if it shares a groupId with another consumer. To avoid offset commit conflicts, you should usually ensure that the groupId is unique for each consumer instance.
一旦分配分区，你就可以在循环中调用poll（跟前面的例子一样），消费者指定的组仍用于提交offset，但是其分区组只能通过通过assign来手工实现，而不能享受自动分配。所以，当消费者出现异常的时候，不会导致分区的重新分配。每一个消费者是独立工作的，（包括共享GroupId的consumer），因此为了避免offset提交冲突，通常你需要确认每一个consumer实例的gorupId都是唯一的。

感谢支持~！已改正。

zookeeper 是作为性能协调工具的角色存在。存储着你Kafka服务的一些些元数据（partitions、offset等等）。zookeeper集群的作用在于保证Zookeeper服务的高可用。因此你可以根据你的需要来选择是否构建zookeeper集群。

发布订阅魔兽：消息广播给所有的消费者

typo: "魔兽" -> "模式"

写得真好，值得学习。