Hi, this is a very novice question. A basic operation is failing for me therefore seeking guidance. I'm creating the following table in Flink with kafka as a sink. I'm running the sql statements in sql-client in interactive mode. The topic

transactions

(1 partition, 1 replica) exists in kafka, running on a wurstmeister/kafka docker container.

CREATE TABLE transactions
(
    `account_id` BIGINT,
    `amount`     BIGINT
) WITH (
      'connector' = 'kafka',
      'topic' = 'transactions',
      'properties.bootstrap.servers' = 'localhost:59092',
      'properties.group.id' = 'testGroup',
      'scan.startup.mode' = 'earliest-offset',
      'format' = 'json');

Then I run

insert into transactions  values (1, 23);

After the above insert, I expected the record to appear as an event in the

transactions

topic but it does not. If I run select * from transactions, I can see the record in the table. Just not in kafka. Any pointers would be much appreciated.