-
Notifications
You must be signed in to change notification settings - Fork 1k
Open
Labels
Description
Describe the bug
The /query-stream
endpoint does not return TOMBSTONE messages.
https://docs.confluent.io/platform/current/ksqldb/developer-guide/ksqldb-rest-api/streaming-endpoint.html#ksqldb-rest-api-query-stream-endpoint
There is no way to get deletion information using it.
To Reproduce
Steps to reproduce the behavior, include:
- versio `7.8.1.
CREATE SOURCE TABLE `ExampleTable` (`id` STRING PRIMARY KEY, `value` STRING) WITH (KAFKA_TOPIC='exampleTopic', KEY_FORMAT='KAFKA', PARTITIONS=1, VALUE_FORMAT='JSON');
CREATE STREAM `ExampleStream` (`id` STRING KEY) WITH (KAFKA_TOPIC='exampleTopic', VALUE_FORMAT='KAFKA');
curl -X "POST" "http://localhost:8088/query-stream" \
-d $'{
"sql": "SELECT * FROM `Example` EMIT CHANGES;",
"streamsProperties": {}
}'
INSERT INTO `ExampleStream` (`id`) VALUES ('test');
- A clear and concise description of what you expected to happen.
Actual behaviour
I have attached screenshots that show the endpoint calls and the ksql table and stream creation and what ouputs are visible