Я использую KSQL для обработки данных Kafka.Я могу создавать постоянные потоки kafka, но тема вывода для этого потока не является сжатой.Как определить тип сжатия при создании потока.
CREATE STREAM TARGET_TOPIC WITH **(COMPRESSION='SNAPPY')** AS SELECT * FROM SOURCE PARTITION BY ID
Я ожидаю дать конфигурацию сжатия, как указано выше, но приведенный выше синтаксис неверенЕсли сжатие возможно в ksql, пожалуйста, помогите в этом.
Спасибо