I created a stream and table using ksqldb client
using
ksql> version;
Version: 0.20.0
CREATE STREAM enrichedeventsstream (
key VARCHAR KEY,
id VARCHAR,
eventTitle VARCHAR,
...
...
WITH (KAFKA_TOPIC='enrichedevents', PARTITIONS=8, VALUE_FORMAT='JSON');
and
CREATE TABLE enrichedevents (
key VARCHAR PRIMARY KEY,
id VARCHAR,
eventTitle VARCHAR,
...
WITH (KAFKA_TOPIC='enrichedevents', PARTITIONS=8, VALUE_FORMAT='JSON');
In both cases we can see data using pull queries;
select * from enrichedevents where key='500419843:3124' emit changes;
select * from enrichedeventsstream emit changes;
I created a materialized view table:
CREATE TABLE enrichedevents_queryable AS
SELECT key ,
id,
eventTitle from enrichedevents;
but when I try to query as
select * from enrichedevents_queryable where key='500419843:3124' ;
I get no data returned.
What am I doing wrong?