apache-kafka - 在kafka KSQL引擎中运行选择查询时出现java空指针异常

Question

脚步 ：

1. 我们创建了一个名为 Kafka 的主题pgsqlcountry，其中包含来自 postgreSQL DB 的所有流数据。

2. 我们创建了一个流country，用于将主题处理成表格。

3. 流创建成功。

-

ksql> describe country;

Field      | Type
------------------------------
ROWTIME    | BIGINT
ROWKEY     | VARCHAR(STRING)
ID         | BIGINT
COUNTRY    | VARCHAR(STRING)
CREATED_AT | BIGINT
UPDATED_AT | BIGINT

-

4. 我们运行 SQL 命令“select * from country”

5. 我们得到如下错误

-

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

请在此屏幕截图中找到我的堆栈跟踪

Answer 1

当我有 时java.lang.NullPointerException，我有不兼容的 ksqldb 图像版本。

似乎有cp前缀图像，例如

• cp-ksqldb-服务器
• cp-ksqldb-cli

不要与这些图像混搭（尽量坚持使用一组或另一组）：

• sqldb-服务器
• ksqldb-cli

您可以运行一些其他命令（例如SHOW PROPERTIES;），看看这是否也会给出相同的错误java.lang.NullPointerException。如果是这样，它可能是图像。