ksql icon indicating copy to clipboard operation
ksql copied to clipboard

The /query-stream endpoint does not return TOMBSTONE messages

Open mrt181 opened this issue 9 months ago • 0 comments

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:

  1. 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');
  1. 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

Image Image Image

mrt181 avatar Mar 20 '25 10:03 mrt181