kafka java api lab 源码

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