Function create_kafka_streaming_table 

pub fn create_kafka_streaming_table(
    schema: SchemaRef,
    config: KafkaConfig,
) -> Result<Arc<dyn TableProvider>>

Build a DataFusion StreamingTable backed by a live Kafka/Redpanda topic.

Enables rdkafka auto-commit at 1 s intervals for at-least-once delivery. Callers that prefer SQL DDL can use CREATE EXTERNAL TABLE … STORED AS KAFKA.