Search code examples
apache-kafkaapache-kafka-streamsapache-kafka-connectkafka-join

Can't we join two tables and fetch data in Kafka?

I have joined two tables and fetched data using Postgres source connector. But every time it gave the same issue i.e. enter image description here

I have run the same query in Postgres and it runs without any issue. Is fetching data by joining tables not possible in Kafka?

Solution

  • I solve this issue by using the concept of the subquery. The problem was that
    when I use an alias, the alias column is interpreted as a whole as a column name and therefore the problem occurs. Here goes my query: 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"