文件名称：kmq：基于Kafka的消息队列
文件大小：261KB
文件格式：ZIP
更新时间：2024-02-26 17:19:29
java scala kafka akka reactive-streams
Kafka消息队列 使用kmq您可以在Kafka中确认对单个消息的处理，并且可以在超时后重新发送未确认的消息。 这与通常的Kafka偏移量提交机制相反，在该机制下，您只能确认直到给定偏移量的所有消息。 如果您熟悉 ，则kmq实现类似的消息处理模型。 这是如何运作的？ 有关更深入的概述，请参见博客：，以及性能基准： 确认机制使用marker主题，该marker主题的分区数应与“主要”数据主题（称为queue主题）相同。 标记主题用于通过为每个消息编写开始/结束标记来跟踪已处理的消息。 使用kmq 使用kmq的应用程序应包含以下组件： 一些RedeliveryTracker 。 该组
【文件预览】：
kmq-master
----core()
--------src()
----kmq.png(232KB)
----LICENSE(11KB)
----build.sbt(3KB)
----.gitignore(121B)
----project()
--------plugins.sbt(50B)
--------build.properties(18B)
----README.md(5KB)
----example-java()
--------src()
----example-scala()
--------src()