dataframes我想以kafka格式写入一个流avro；
dataframes
kafka
avro
我认为我应该将dataframe模式发布为schema registry模式avro，然后将 DF 流写入 kafka，并指定该模式作为选项。
dataframe
schema registry
所以我需要知道如何avro从 中推断模式dataframe以便能够在schema registry.
如果有其他方式我将不胜感激
scala avro apache-kafka apache-spark confluent-schema-registry
apache-kafka ×1
apache-spark ×1
avro ×1
confluent-schema-registry ×1
scala ×1