步骤:
我们创建了一个Kafka主题,叫做 pgsqlcountry
它拥有来自postgresql数据库的所有流数据。
我们创建了一个名为 country
用于将主题处理到表中。
已成功创建流。
ksql> describe country;
Field | Type
------------------------------
ROWTIME | BIGINT
ROWKEY | VARCHAR(STRING)
ID | BIGINT
COUNTRY | VARCHAR(STRING)
CREATED_AT | BIGINT
UPDATED_AT | BIGINT
我们运行sql命令“select*from country”
我们得到如下错误
ksql> select * from country;
null | null | null | null | null | null
Exception in thread "ksql_query_1-8f1f36a7-e83c-476d-8561-98fe9ed8866b-StreamThread-2" java.lang.NullPointerException
请在这个截图中找到我的stacktrace
暂无答案!
目前还没有任何答案,快来回答吧!