apache-kafka - KSQL 连接返回空字段

Question

我正在尝试加入以下流

 Field     | Type
---------------------------------------
 ROWTIME   | BIGINT           (system)
 ROWKEY    | VARCHAR(STRING)  (system)
 USER_ID   | VARCHAR(STRING)
 FIRSTNAME | VARCHAR(STRING)
---------------------------------------

下表：

 Field     | Type
---------------------------------------
 ROWTIME   | BIGINT           (system)
 ROWKEY    | VARCHAR(STRING)  (system)
 USER_ID   | VARCHAR(STRING)
 USERNAME  | VARCHAR(STRING)
---------------------------------------

使用

SELECT M.USER_ID, \
       C.USERNAME \
FROM MY_STREAM M \
LEFT JOIN MY_TABLE C \
ON (M.USER_ID = C.USER_ID);

但USERNAME只包含null值。

1 | null
2 | null
3 | null
4 | null
5 | null
6 | null
7 | null
8 | null

我确信有 common user_ids 并且没有username在null表中。我在这里错过了什么吗？

Answer 1

请参阅我对这篇文章的回答，其中我演示了如何解决这样的连接问题。

简而言之，您需要在您加入的列上键入表主题中的消息。

如果你打算加入USER_ID然后：

SELECT ROWKEY, USER_ID FROM MY_TABLE

应该返回

1 | 1 
2 | 2
3 | 3

ETC