我有两个 Kafka 流。 例如，第一个 - 没有键，但我们有一个（非唯一，考虑到消息速率）时间戳。1,3,5,7,9 第二个，例如： - 即某物为第一个主题中的值分配了一个键，并且（可逆地）更改...

我有一个包含损坏消息的旧主题，我需要完全重新处理该主题，忽略无法处理的消息。对于此方案，哪种正确的未捕获异常处理策略？ 我无法完全理解 KStreams 应用程序上未捕获异常处理的 REPLACE_...

我使用 spring boot 版本 2.5.3、spring-cloud-stream-binder-kafka-stream 版本 3.1.3 和 kafka-clients 版本 2.8.0。我...

我有一个简单的应用程序，它将使用来自 topicA 和 topicB 的两个流，将它们转换为 KTables，然后使用外键连接两个表。然后，将联接的结果发送到输出主题。在本地环境中，应用程序运行良好，...

我们将 Avro 方案用于代表“公共”接口的 kafka 主题。现在，当在 Kafka-Streams 应用程序中使用此类主题并调用有状态操作时，将再次自动使用内部名称注册相同的架构。 处理这个问题...