KSQLDB表没有返回预期的数据

Question

我从Kafka主题创建了一个表，然后我想用表连接一个流，但是表是空的，连接的结果是空的。我的Kafka主题有一些数据，主题上的流工作，但我无法在表中看到任何数据。

CREATE TABLE book (
ID int PRIMARY KEY,
title varchar(50) ) WITH (
kafka_topic = 'books.story',
value_format = 'avro');

我有一个流

CREATE STREAM store WITH (
kafka_topic = 'store.hafez',
value_format = 'avro');

现在我想连接这个流和表:

CREATE STREAM stories As
select * from store AS st
left join book AS bs
on bs.ID = st.BookID;

我无法在包含表数据的stories流中看到任何记录，而我确信它应该有来自这方面的一些数据。

Answer 1

当我创建一个表时，主题中的新记录没有更新表，因此连接结果，特别是内部连接，没有返回任何东西。所以我创建了一个流，而不是一个表，因为我想加入所有的记录在书中，我设置流的窗口加入100天内，然后它工作。

CREATE STREAM stories As
select * from store AS st
left join book AS bs
within 100 days
on bs.ID = st.BookID;