I have a stream with an event_type field, possible values are (view, cart,
purchase).
CREATE STREAM events(event_type STRING)
WITH (KAFKA_TOPIC='events', VALUE_FORMAT='DELIMITED');
I want to count the total number of all events or percentage for each
event_type, and the number of events for each
>
>SELECT event_type as event_type, COUNT(event_type) AS total
>
>FROM EVENTS GROUP BY event_type;
>
> ```
>
> That you can query using a push query:
>
> ```
>
> SELECT * FROM events_per_type EMIT CHANGES;
>
> ```
>
> Thanks,
>
I have a stream with an event_type field, possible values are (view, cart,
purchase).
CREATE STREAM events(event_type STRING)
WITH (KAFKA_TOPIC='events', VALUE_FORMAT='DELIMITED');
I want to count the total number of all events and the number of events for
each event_type into a single table.
The issue description formatted on stackoverflow :
https://stackoverflow.com/questions/61919200/field-does-not-exist-on-transformations-to-extract-key-with-debezium
kafka.bootstrap.servers" = 'kafka:29092',
"database.history.kafka.topic" = 'dbz.deepprices',
"include.schema.changes" = 'true',
"key.converter" = 'org.apache.kafka.connect.json.JsonConverter',
"key.converter.schemas.enable" = 'TRUE',
Hi there,
I am having an issue with Cassandra connector :
https://stackoverflow.com/questions/61897693/dataexception-key-must-be-a-struct-or-map
Thank you so much for your help
--
Mohammed Ait Haddou
Linkedin.com/in/medait
+212697937189
PICS: "^_.*"
# Other systems
mysql:
# *-*
# To connect to the DB:
# docker exec -it mysql bash -c 'mysql -u root -p$MYSQL_ROOT_PASSWORD'
# or
# docker exec -it mysql bash -c 'mysql -u $MYSQL_USER -p$MYSQL_PASSWORD demo'
# *-*
image: debezium/example-mysql:1.1
container_name: mysql
ports:
- 3306:3306
environment:
- MYSQL_ROOT_PASSWORD=root
- MYSQL_USER=user
- MYSQL_PASSWORD=pwd
--
Mohammed Ait Haddou
Linkedin.com/in/medait
+212697937189
