python (65.1k questions)
javascript (44.2k questions)
reactjs (22.7k questions)
java (20.8k questions)
c# (17.4k questions)
html (16.3k questions)
r (13.7k questions)
android (12.9k questions)
Is it possible to query a KSQL Table/Materialized view via HTTP?
I have a materialized view created using
CREATE TABLE average_latency AS SELECT DEVICENAME, AVG(LATENCY) AS AVG_LATENCY FROM metrics WINDOW TUMBLING (SIZE 1 MINUTE) GROUP BY DEVICENAME EMIT CHANGES;
...
Sourabh Mokhasi
Votes: 0
Answers: 2
How to create an output stream (changelog) based on a table in KSQL correctly?
Step 1: Create table
I currently have a table in KSQL which created by
CREATE TABLE cdc_window_table
WITH (KAFKA_TOPIC='cdc_stream',
VALUE_FORMAT='JSON') AS
SELECT after->application_...
Hongbo Miao
Votes: 0
Answers: 0
Perform streaming aggregations on CDC events that contain deletes/updates
A friend reached out and told me that he'd built a data pipeline that captures changes from MySQL using the Debezium connector, and then performs streaming aggregations on the events using ksqlDB.
At...
Alex Woolford
Votes: 0
Answers: 0
Dynamic JSON structure (TM Forum Spec) in a ksqldb stream in Kafka?
Good morning, everyone. I need to create a stream to parse the below structure. Specifically, I need to do some data routing based on the ->event->appointment->category value. As I underst...
Dustin Wilson
Votes: 0
Answers: 0