Function register_kafka_source 

pub fn register_kafka_source(registry: &ConnectorRegistry)

Registers the Kafka source connector with the given registry.

After registration, the runtime can instantiate KafkaSource by name when processing CREATE SOURCE ... WITH (connector = 'kafka').