Hi contributors, Sorry to bother you! I met a problem when I was trying to apply a windowing aggregation Beam SQL query to a Kafka input source.
The details of the question are in the following link: https://stackoverflow.com/questions/63566057/how-to-integrate-beam-sql-windowing-query-with-kafkaio. And the version of the Beam Java SDK I used is *2.23.0* Really appreciate your help and advice! Stay safe and happy! Thanks and regards, Minreng
