我在 pyspark 中有一个嵌套的滑动窗口，在 outputMode = “append” 中有一个 kafka sink。只有滑动窗口的第一个 groupBy，我有一个与我最初的 5 分钟大小相匹...

我有一个长期运行的任务，即上传一个 CSV，根据该 CSV 插入大量记录;所以我把它委托给 Kafka。 这些插入操作需要经过身份验证，这意味着我发出了经过身份验证的 API 请求。 我的问题基本上...

我正在尝试使用 Jackson 库从 Kafka 主题中读取字符串并从另一个流执行连接。 下面是一个包含两个数据流的示例代码。我想对这些消息流执行联接操作。 例如，传入的流是： messageS...

我有一个java，springboot项目，我使用Kafka进行异步通信。有一个 Kafka 生产者，它执行一些逻辑并将记录保存到数据库中。然后，它引发一个事件，该事件由使用者使用，而使用者又在弹性搜...

在实现 UDTF ROW_NUM之前，我试图理解，我想知道 UTDF 是否可以在计算时在所有行中进行排序以返回为结构类型？ https://docs.ksqldb.io/en/0.7.1-ksqld...

我正在测试kafka-lag-exporer 。我在本地机器上设置了 kafka-server、zookeper、prometheus 和 grafana。我创建了一个名为 Kafka 主题和使用者组...