akka-kafka
-
为什么启用自动提交的 Kafka 客户端会在消费者关闭期间提交最新生成的消息的偏移量，即使消息尚未被消费？
-
快速处理主题和慢速处理主题 - Akka Kafka
-
这个 Akka Kafka Stream 配置是否受益于 Akka Streams 的背压机制？
-
akka-Kafka（scala 框架）中是否有列出所有可用主题的功能
-
AVRO 模式更新的问题
-
使用 Akka Kafka Streams 时不兼容的等式约束
-
与 websocket 连接时使用 akka-stream-kafka 从 kafka Topic 获取最后一条消息
-
Akka 流过滤后的 kafka 提交偏移量
-
使用reactive-kafka有条件地处理消息
-
在 Kafka 主题中使用了所有可用消息后，您如何 return 包含消息列表的未来？
-
处理消息后提交 Kafka 消费者偏移量的好模式是什么？
-
Reactive-Kafka Stream Consumer：出现死信
-
Akka Stream TCP + Akka Stream Kafka 生产者不停止不发布消息并且不出错