Expand description

Provides parsing and convenience functions for working with Kafka from the sql package.


Config 🔒

Gets error strings from rdkafka when creating test consumers.


ValType 🔒


Create a new rdkafka::ClientConfig with the provided options, and test its ability to create an rdkafka::consumer::BaseConsumer.

extract 🔒

Parse the with_options from a CREATE SOURCE or CREATE SINK statement to determine user-supplied config options, e.g. security options.

Returns start offsets for the partitions of topic and the provided kafka_time_offset option.