Problems sinking a Flink table to Kafka

[Ralph Matthias Debusmann]

Hi,

I am stumbling on the next Flink SQL problem - but I am sure you can help
me :)

I have an extremely simple table called "bla" which just has one column of
type double. Now I want to sink that table into a Kafka topic. This is how
I do it:


CREATE TABLE bla_sink (
total DOUBLE,
PRIMARY KEY (total) NOT ENFORCED
) WITH (
'connector' = 'upsert-kafka',
'property-version' = 'universal',
'properties.bootstrap.servers' = 'localhost:9092',
'topic' = 'total',
'key.format' = 'json',
'value.format' = 'json',
'properties.group.id' = 'bla_sink'
);
This does go through but the topic doesn't receive any messages... what
could be the problem? The primary key?

Best,
Ralph