首页 项目目录 关于我们
Sign In
rust
/
Materialize
1
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Branch: master
Branches Tags
Materialize
/
test
/
legacy-upgrade
/
check-from-v0.111.0-kafka-sink.td

check-from-v0.111.0-kafka-sink.td 1.7 KB
Permalink History Raw

1234567891011121314151617181920 
  1. # Copyright Materialize, Inc. and contributors. All rights reserved.
    2. 

  2. #
    3. 

  3. # Use of this software is governed by the Business Source License
    4. 

  4. # included in the LICENSE file at the root of this repository.
    5. 

  5. #
    6. 

  6. # As of the Change Date specified in that file, in accordance with
    7. 

  7. # the Business Source License, use of this software will be governed
    8. 

  8. # by the Apache License, Version 2.0.
    9. 

  9. 

  10. > SHOW CREATE SINK compression_implicit;
    11. 

  11. materialize.public.compression_implicit "CREATE SINK materialize.public.compression_implicit IN CLUSTER quickstart FROM materialize.public.kafka_sink_from INTO KAFKA CONNECTION materialize.public.kafka_conn (TOPIC = 'kafka-sink') FORMAT JSON ENVELOPE DEBEZIUM;"
    12. 

  12. 

  13. > SHOW CREATE SINK compression_none_explicit;
    14. 

  14. "materialize.public.compression_none_explicit" "CREATE SINK materialize.public.compression_none_explicit IN CLUSTER quickstart FROM materialize.public.kafka_sink_from INTO KAFKA CONNECTION materialize.public.kafka_conn (TOPIC = 'kafka-sink', COMPRESSION TYPE = 'none') FORMAT JSON ENVELOPE DEBEZIUM;"
    15. 

  15. 

  16. > SHOW CREATE SINK compression_lz4_explicit;
    17. 

  17. "materialize.public.compression_lz4_explicit" "CREATE SINK materialize.public.compression_lz4_explicit IN CLUSTER quickstart FROM materialize.public.kafka_sink_from INTO KAFKA CONNECTION materialize.public.kafka_conn (TOPIC = 'kafka-sink', COMPRESSION TYPE = 'lz4') FORMAT JSON ENVELOPE DEBEZIUM;"
    18. 

  18. 

  19. > SHOW CREATE SINK compression_gzip_explicit;
    20. 

  20. "materialize.public.compression_gzip_explicit" "CREATE SINK materialize.public.compression_gzip_explicit IN CLUSTER quickstart FROM materialize.public.kafka_sink_from INTO KAFKA CONNECTION materialize.public.kafka_conn (TOPIC = 'kafka-sink', COMPRESSION TYPE = 'gzip') FORMAT JSON ENVELOPE DEBEZIUM;"
    21.