spark-kafka-integration
-
Spark Streaming 和 Kafka 集成中的并行任务数
-
如何使用 subscribePattern 订阅新主题?
-
Spark 3 结构化流在 Kafka 源代码中使用 maxOffsetsPerTrigger Trigger.Once
-
Kafka 中的 Spark 偏移量管理
-
Apache Spark 与 Kafka 集成
-
如何在 spark 3.0 结构化流中使用 kafka.group.id 和检查点继续从重启后停止的 Kafka 读取?
-
Spark 3.x 在 Python 中与 Kafka 集成
-
具有 SASL_SSL 身份验证的 Kafka Spark 结构化流
-
如何在Structured Streaming中为kafka数据源中的消费者组设置group.id?