我正在寻找PySpark的相关库，以从Kafka获取架构注册表并解码数据。有谁知道在scala代码中从scala转换为pyspark的代码/库是什么？
您可以使用requests包将请求发送到schema-registryrestAPI并获取主题的架构，并且，如果您正在侦听某些特定主题，则可以在spark上缓存它们的架构并使用它们
requests
schema-registry
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
点击生成二维码
我来说两句