fn kafka_sink_builder(
scx: &StatementContext<'_>,
connection: ResolvedItemName,
options: Vec<KafkaSinkConfigOption<Aug>>,
format: Option<FormatSpecifier<Aug>>,
relation_key_indices: Option<Vec<usize>>,
key_desc_and_indices: Option<(RelationDesc, Vec<usize>)>,
headers_index: Option<usize>,
value_desc: RelationDesc,
envelope: SinkEnvelope,
sink_from: GlobalId,
) -> Result<StorageSinkConnection<ReferencedConnection>, PlanError>