【文件属性】：
文件名称：kafka-java-api-lab
文件大小：20.81MB
文件格式：ZIP
更新时间：2021-02-12 15:33:54
Java
卡夫卡课程的测试项目
该项目包含通过Java API使用Kafka的不同示例。
关于kafka的信息
话题
主题在文件中包含日志更改消息。
拓扑由至少一个分区组成。
消息由键和值组成。
消息分布在分区中，分布是通过算法完成的。
该算法可循环，杂音3或自定义（实现特定类）。 这些算法将使用密钥作为输入来确定每个消息的位置（在分区中）。 因此，相同的密钥将始终位于同一分区中。
隔断
一个分区由单个代理程序管理，但将取决于复制因素，将其复制到其他代理程序。 因此，其中一个代理将具有分区负责人，将从中接收消息。 分区上的更改将自动复制到其他代理。
如果代理发生故障，集群将自动选择另一个分区负责人。
复制品
复制因子的最大值应等于代理的数量。
每个副本将自动同步。
制片人
负责向主题发送消息。
可以通过配置选项将消息发送到特定分区。
它连接到分区领导者，以使用正确的代理发送消息。
消
【文件预览】：
kafka-java-api-lab-master
----src()
--------main()
----README.md(4KB)
----pom.xml(2KB)
----docs()
--------documentacion-kafka-desarrollo-alumnos.pdf(25.87MB)
--------documentacion-patrones-arquitectura-alumnos.pdf(3.79MB)
----docker-compose.yml(1KB)
----.gitignore(56B)