kafka-java-api-lab

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