卡夫卡课程的测试项目 该项目包含通过Java API使用Kafka的不同示例。 关于kafka的信息 话题 主题在文件中包含日志更改消息。 拓扑由至少一个分区组成。 消息由键和值组成。 消息分布在分区中，分布是通过算法完成的。 该算法可循环，杂音3或自定义（实现特定类）。 这些算法将使用密钥作为输入来确定每个消息的位置（在分区中）。 因此，相同的密钥将始终位于同一分区中。 隔断 一个分区由单个代理程序管理，但将取决于复制因素，将其复制到其他代理程序。 因此，其中一个代理将具有分区负责人，