Closed harshitmahapatra closed 3 years ago
If anyone else encounters the same issue, It was my mistake. I should have used
client.query('SELECT * FROM stream_name EMIT CHANGES LIMIT 5;')
instead of
client.ksql('SELECT * FROM stream_name EMIT CHANGES LIMIT 5;')
Queries like:
don't work and throw the following error:
P.S. Queries like
work fine.