本文基于kafka3.6
本文基于Spark3.4.1
本文基于kafka2.8.0版本
本文基于kafka3.7，描述Kafka在生产消息性能模型
汇总kafka消费失败的场景
本文基于Kafka2.7
kyuubi提供了一种ranger plugin，用于对spark任务的鉴权
Kafka是中间件，对于消费完成的数据，需要有清理机制来保障集群的正常运行。
Kafka数据文件运行时提供checkpoint机制，保证数据的一致性
nieo
发布于 2024-05-17