Module sql::kafka_util [−][src]
Expand description
Provides parsing and convenience functions for working with Kafka from the sql
package.
Structs
Gets error strings from rdkafka
when creating test consumers.
Enums
Functions
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.