Expand description

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


Gets error strings from rdkafka when creating test consumers.


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

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.