首页 > 解决方案 > 有没有办法将发布到 Kafka 主题的 Avro 文件转换为 python 中的平面 SQL 表?

问题描述

我有一个 Avro 模式(avsc 文件)和以 Avro 格式在 kafka 主题中发布的数据,我需要将其转换为平面 SQL 表。

标签: pythonsqlapache-kafkaavro

解决方案


如果数据是由 Confluent Avro 序列化程序之一生成的,您可以使用他们的 Kafka Connect JDBC Sink 写入您选择的 SQL 数据库(例如 sqlite,如果您确实需要文件)

否则,您将需要为此用例编写自己的 Python 代码


推荐阅读