结构化流 + Kafka 集成 - SSL 和 Kerberos 集成？
Posted
技术标签:
【中文标题】结构化流 + Kafka 集成 - SSL 和 Kerberos 集成？【英文标题】：Structured Streaming + Kafka Integration - SSL and Kerberos Integration? 【发布时间】：2017-05-24 00:27:34 【问题描述】：我正在尝试从常规流媒体切换到结构化流媒体是否值得。 Spark 2.1.x 结构化流是否支持从受保护的 Kafka (SSL_SASL) 消费。意思是 Kerberos 和 SLL。
【问题讨论】：
【参考方案1】：Spark Streaming 和 Structured Streaming 使用相同的 Kafka 客户端。安全 Kafka 的配置相同。
【讨论】：
以上是关于结构化流 + Kafka 集成 - SSL 和 Kerberos 集成？的主要内容，如果未能解决你的问题，请参考以下文章
Flask - 拉取实时流 kafka 数据 - 将 Kafka 与 Python Flask 集成
如何在 Spark 结构化流中手动设置 group.id 并提交 kafka 偏移量？
如何从 Spark 结构化流中的 Cassandra 等外部存储读取 Kafka 和查询？