I got it working now: It needs to be specified both for the key and value
thanks
Am Mo., 28. März 2022 um 13:33 Uhr schrieb Ingo Bürk :
> Hi Georg,
>
> which Flink version are you using? The missing property is for the
> avro-confluent format, and if I recall correctly, how these are passed
>
Hi Georg,
which Flink version are you using? The missing property is for the
avro-confluent format, and if I recall correctly, how these are passed
has changed in recent versions, so it'd be good to double check you are
using the documentation for the version you are running on.
Best
Ingo
Hi,
how can I get Flinks SQL client to nicely sink some data to either the
regular kafka or the kafka-upsert connector?
I have a table/ topic with dummy data:
CREATE TABLE metrics_brand_stream (
`event_time` TIMESTAMP(3) METADATA FROM 'timestamp',
WATERMARK FOR event_time AS event_time -
