'How to manipulate Kafka key documents with KSQLDB?

I have a problem. I can't find a way to create a stream by filtering on the key of a kafka document.

I would like to filter and manipulate the json of a kafka key to retrieve the payload of the following example which corresponds to my couchbase id:

ksql> print 'cb_bench_products-get_purge' limit 1;

Key format: JSON or HOPPING(KAFKA_STRING) or TUMBLING(KAFKA_STRING) or KAFKA_STRING
Value format: JSON or KAFKA_STRING

rowtime: 2022/03/04 10:49:43.643 Z, key: {"schema":{"type":"string","optional":false},"payload":"history::05000228023411_RO_RO11219082::80"}, value: {[...]}}

ksqldb

Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution	Source

'How to manipulate Kafka key documents with KSQLDB?

Sources

Related Questions