KafkaRecordToRowConverter¶

kafkaSchema¶

kafkaSchema(
  includeHeaders: Boolean): StructType

kafkaSchema is schemaWithHeaders for the given includeHeaders enabled. Otherwise, kafkaSchema is schemaWithoutHeaders.

kafkaSchema is used when:

• KafkaRelation is requested for the schema
• KafkaScan is requested for the readSchema
• KafkaSource (Spark Structured Streaming) is requested for the schema
• KafkaSourceProvider is requested for the sourceSchema
• KafkaTable is requested for the schema