ReadWriteKafkaTableSQLAPI Read from Kafka and aggregate data using Table and SQL API, writing back to Kafka