Skip to content

table creation failed #1

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
hishamag-student opened this issue Jan 4, 2024 · 0 comments
Open

table creation failed #1

hishamag-student opened this issue Jan 4, 2024 · 0 comments

Comments

@hishamag-student
Copy link

hishamag-student commented Jan 4, 2024

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";

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant