samples/ydb_service/ydb/migrations/0002_records_changefeed.sql

-- +goose Up
CREATE TABLE `records` (
      id Utf8,
      name Utf8,
      str String,
      num Uint64,
      PRIMARY KEY(id, name)
);
 
ALTER TABLE `records` ADD CHANGEFEED `changefeed`
WITH (
    FORMAT = 'JSON',
    MODE = 'NEW_AND_OLD_IMAGES'
);
 
ALTER TOPIC `records/changefeed` ADD CONSUMER `sample-topic-consumer`;
ALTER TOPIC `records/changefeed` ADD CONSUMER `sample-federated-topic-consumer`;