在kafka ksql引擎中运行select查询时发生java空指针异常

ddhy6vgd  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(194)

步骤:
我们创建了一个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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题