Module sql::kafka_util

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

Structs

Config

KafkaErrCheckContext

Gets error strings from rdkafka when creating test consumers.

Enums

ValType

Functions

create_consumer

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

extract

extract_config

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

fetch_end_offset

generate_ccsr_client_config

lookup_start_offsets

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