# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in accordance with # the Business Source License, use of this software will be governed # by the Apache License, Version 2.0. # # Test the case where we fail to publish the schema of the reader # $ kafka-create-topic topic=resolution-no-publish-writer # The schema is {"type": "record", "name": "schema_int", "fields": [ {"name": "f1", "type": "int"} ] }. # and the value is {"f1": 123} # We encode it manually to avoid publishing it. $ kafka-ingest format=bytes topic=resolution-no-publish-writer timestamp=1 \\x00\x00\x00\x00\x01\xf6\x01 > DROP SCHEMA IF EXISTS public CASCADE > CREATE SCHEMA public > CREATE CONNECTION IF NOT EXISTS csr_conn TO CONFLUENT SCHEMA REGISTRY ( URL "${testdrive.schema-registry-url}" ); > CREATE CONNECTION kafka_conn TO KAFKA (BROKER "${testdrive.kafka-addr}"); ! CREATE SOURCE resolution_no_publish_writer FROM KAFKA CONNECTION kafka_conn (TOPIC "testdrive-resolution-no-publish-writer-${testdrive.seed}") FORMAT AVRO USING CONFLUENT SCHEMA REGISTRY CONNECTION csr_conn ENVELOPE NONE contains:No value schema found
Related articles
Materialize information_schema_tables
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize relation cse
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize reduce_fusion
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize shift
# Copyright 2015 - 2019 The Cockroach Authors. All rights reserved. # Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of thi
Materialize check from v0.45.0 kafka progress
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize 64 concurrent delete same
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize github 9027
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize create in v0.27.0 time literals
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a
Materialize delete
# Copyright 2015 - 2019 The Cockroach Authors. All rights reserved. # Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of thi
Materialize concurrent ddl
# Copyright Materialize, Inc. and contributors. All rights reserved. # # Use of this software is governed by the Business Source License # included in the LICENSE file at the root of this repository. # # As of the Change Date specified in that file, in a