For the sake of completeness of functionality, consistency and testing purposes it's required to implement support for INSERT query for Kafka Engine. It also implies support for MATERIALIZED and DEFAULT columns.