Kafka Simple Test

a.txt

kafka-topics --create --bootstrap-server localhost:29092 --replication-factor 1 --partitions 4 --topic my-topic

create table t1 (v1 int, v2 varchar, t timestamptz as proctime()) with (
  connector = 'kafka',
  topic = 'my-topic',
  properties.bootstrap.server = '127.0.0.1:29092',
  scan.startup.mode = 'earliest'
) row format json;

create source s1 (v1 int, v2 varchar, t timestamptz as proctime()) with (
  connector = 'kafka',
  topic = 'my-topic',
  properties.bootstrap.server = '127.0.0.1:29092',
  scan.startup.mode = 'earliest'
) row format json;


kafka-console-producer --broker-list localhost:29092 --topic my-topic
>{"v1":1, "v2":"hello"}