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

【问题标题】：java null pointer exception while running select query in kafka KSQL engine在kafka KSQL引擎中运行选择查询时出现java空指针异常
【发布时间】：2021-05-27 22:46:55
【问题描述】：

步骤：

我们创建了一个名为 pgsqlcountry 的 Kafka 主题，其中包含所有从 postgreSQL DB 流式传输数据。
我们创建了一个名为 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

请找到我的堆栈跟踪in this screenshot

【问题讨论】：

我收到此错误“警告 KsqlJsonDeserializer 无法反序列化主题的数据：pgsqlsampletest (io.confluent.ksql.serde.json.KsqlJsonDeserializer:91)”
您最好将此作为问题记录在 KSQL github 上。请不要将屏幕截图用于堆栈跟踪 - 它们是文本！
还包括 CREATE STREAM 声明（是分隔的还是 JSON 格式）和主题本身的输出，例如kafkacat
您能否在您的主题中提供一个示例行以及您使用的 CREATE STREAM 语句。另外你的数据格式是什么？ json?

标签： apache-kafka ksqldb

【解决方案1】：

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

似乎有 cp 前缀图像，例如

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

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

【讨论】：