demo-scene
demo-scene copied to clipboard
Incorrect syntax on kpi-dashboard/dashboard_table.sql
Tagging @krisajenkins for visibility.
I believe this may have been due to a change in the kSQL spec, but the syntax for this table creation no longer works.
The syntax to use now should be:
CREATE OR REPLACE TABLE dashboard
WITH (
KAFKA_TOPIC='dashboard',
PARTITIONS=3,
REPLICAS=3,
VALUE_AVRO_SCHEMA_FULL_NAME='io.confluent.developer.dashboard.DashboardValue',
VALUE_FORMAT='avro'
)
AS
SELECT
'sales' as metric,
sum(price) AS total
FROM purchases
GROUP BY 'sales'
;
✌️