Я использую Kafka KSQL REST API для выполнения запроса (/query
), и внутри ответа я могу получить доступ к результирующим столбцам с помощью этого API: https://docs.confluent.io/current/ksql/docs/developer-guide/api.html#run-a-query-and-stream-back-the-output
row.columns[i] (?) – The value contained in a single column for the row. The value type depends on the type of the column.
Так что я могу получить доступ к значениям столбцов, а не к именам столбцов.
Можно ли как-нибудь получить доступ к именам столбцов, или мне нужно вручную проанализировать запрос KSQL, чтобы получить оттуда имена столбцов?
Например, вместо
[1524760769983,"1",1524760769747,"alice","home"]
Я хотел бы получить {"columnA":1524760769983,"columnB":"1","columnC":1524760769747,"columnD":"alice","columnE":"home"]