table-persistence-after-sinks.td 688 B

1234567891011121314151617181920
  1. # Copyright Materialize, Inc. and contributors. All rights reserved.
  2. #
  3. # Use of this software is governed by the Business Source License
  4. # included in the LICENSE file at the root of this repository.
  5. #
  6. # As of the Change Date specified in that file, in accordance with
  7. # the Business Source License, use of this software will be governed
  8. # by the Apache License, Version 2.0.
  9. > INSERT INTO sink_table VALUES (3)
  10. > SELECT COUNT(*) FROM sink_table
  11. 3
  12. $ kafka-verify-data format=avro sink=materialize.public.sink_sink sort-messages=true
  13. {"before":null, "after":{"row":{"f1":{"int":1}}}}
  14. {"before":null, "after":{"row":{"f1":{"int":2}}}}
  15. {"before":null, "after":{"row":{"f1":{"int":3}}}}