Hei, I am trying to create a table from connector kafka like this:

CREATE TEMPORARY TABLE IF NOT EXISTS devices
(
    deviceId STRING PRIMARY KEY NOT ENFORCED,
    userId STRING,
    status STRING,
    pairedOn TIMESTAMP,
    eventTime TIMESTAMP
 )WITH (
      'connector' = 'kafka',
      'topic' = 'devices',
      'format' = 'json',
      'properties.bootstrap.servers' = 'kafka-rt:9093',
      'properties.group.id' = 'ethanol-test',
      'scan.startup.mode' = 'earliest-offset'
      );

but when running the select query I get the following error: org.apache.flink.table.api.ValidationException: The Kafka table 'default_catalog.default_database.devices' with 'json' format doesn't support defining PRIMARY KEY constraint on the table, because it can't guarantee the semantic of primary key.

That's an error on a different table definition

ah yes, I copied a different table definition my bad but the error still stands

Are you sure? Because this definition doesn't have a PRIMARY KEY defined in it?

this is the table definition for devices

CREATE TEMPORARY TABLE IF NOT EXISTS devices
(
    deviceId STRING PRIMARY KEY NOT ENFORCED,
    userId STRING,
    status STRING,
    pairedOn TIMESTAMP,
    eventTime TIMESTAMP
 )WITH (
      'connector' = 'kafka',
      'topic' = 'devices',
      'format' = 'json',
      'properties.bootstrap.servers' = 'kafka-rt:9093',
      'properties.group.id' = 'ethanol-test',
      'scan.startup.mode' = 'earliest-offset'
      );

Ah

oh really!

Primary key is only possible with upsert-kafka

ok