You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Create "Table" and "Streams" in KSQL, see them getting reflected in PostgreSQL kafKa_test.
can you please provide me with an example of table and how to link it, to produce the table on postgres after transformations.
I tried this but no table created
CREATE STREAM "event_user" (
identity_id STRING,
name STRING,
family_name STRING,
event_id STRING,
event_type STRING
)
WITH (
KAFKA_TOPIC='event_user',
PARTITIONS=1,
REPLICAS=1,
VALUE_FORMAT='JSON'
);
CREATE STREAM "sink_denormalised_user" WITH (
VALUE_FORMAT='AVRO'
) AS
SELECT
identity_id as "id",
name as "name",
family_name as "family_name",
name + ' ' + family_name AS "full_name",
SUBSTRING(UCASE(name), 1, 1) + SUBSTRING(UCASE(family_name), 1, 1) as "initials",
event_id as "event_id"
FROM "event_user"
EMIT CHANGES
PARTITION BY "id";
The text was updated successfully, but these errors were encountered:
Create "Table" and "Streams" in KSQL, see them getting reflected in PostgreSQL kafKa_test.
can you please provide me with an example of table and how to link it, to produce the table on postgres after transformations.
I tried this but no table created
CREATE STREAM "event_user" (
identity_id STRING,
name STRING,
family_name STRING,
event_id STRING,
event_type STRING
)
WITH (
KAFKA_TOPIC='event_user',
PARTITIONS=1,
REPLICAS=1,
VALUE_FORMAT='JSON'
);
CREATE STREAM "sink_denormalised_user" WITH (
VALUE_FORMAT='AVRO'
) AS
SELECT
identity_id as "id",
name as "name",
family_name as "family_name",
name + ' ' + family_name AS "full_name",
SUBSTRING(UCASE(name), 1, 1) + SUBSTRING(UCASE(family_name), 1, 1) as "initials",
event_id as "event_id"
FROM "event_user"
EMIT CHANGES
PARTITION BY "id";
The text was updated successfully, but these errors were encountered: