apache-kafka - 我们不能在 Kafka 中加入两个表并获取数据吗？

Question

我已经加入了两个表并使用 Postgres 源连接器获取数据。但每次它给出了同样的问题，即

我在 Postgres 中运行了相同的查询，它运行没有任何问题。在 Kafka 中无法通过加入表来获取数据吗？

Answer 1

我通过使用子查询的概念来解决这个问题。问题是
当我使用别名时，别名列被作为一个整体解释为列名，因此出现了问题。这是我的查询： select * from (select p.\"Id\" as \"p_Id\", p.\"CreatedDate\" as p_createddate, p.\"ClassId\" as p_classid, c.\"Id\" as c_id, c.\"CreatedDate\" as c_createddate, c.\"ClassId\" as c_classid from \"PolicyIssuance\" p left join \"ClassDetails\" c on p.\"DocumentNumber\" = c.\"DocumentNo\") as result"