Skip to content

Commit e9ea25a

Browse files
committed
rm protobuf create table syntax
1 parent 18b9427 commit e9ea25a

File tree

5 files changed

+0
-237
lines changed

5 files changed

+0
-237
lines changed

doc/user/content/sql/create-table.md

Lines changed: 0 additions & 75 deletions
Original file line numberDiff line numberDiff line change
@@ -140,79 +140,6 @@ FORMAT AVRO USING CONFLUENT SCHEMA REGISTRY CONNECTION <conn_name>
140140
%}}
141141
{{</ tab >}}
142142

143-
{{< tab "FORMAT PROTOBUF MESSAGE">}}
144-
145-
Creates a read-only table from a [Kafka source](/sql/create-source/), ingesting
146-
messages encoded in PROTOBUF format, specifying the hex encoded schema.
147-
148-
By default, the table contains the columns specified in the schema. You can
149-
include additional columns using the `INCLUDE` options.
150-
151-
{{< tip >}}
152-
153-
- Ensure your messages are raw Protobuf-encoded messages; i.e., ensure they
154-
don't include prefixes, such as Confluent Schema Registry framing prefix.
155-
156-
- If you want to specify an `UPSERT ENVELOPE`, use `KEY FORMAT ... VALUE
157-
FORMAT ...` instead.
158-
159-
{{</ tip >}}
160-
161-
162-
```mzsql
163-
CREATE TABLE <table_name> FROM SOURCE <source_name> [(REFERENCE <ref_object>)]
164-
FORMAT PROTOBUF MESSAGE <msg_name> USING SCHEMA <hex_encoded_schema>
165-
[INCLUDE
166-
PARTITION [AS <name>] | OFFSET [AS <name>]
167-
| TIMESTAMP [AS <name>] | HEADERS [AS <name>] | HEADER <key_name> AS <name> [BYTES]
168-
[, ...]
169-
]
170-
[ENVELOPE NONE] -- Default. Uses the append-only envelope.
171-
[WITH (PARTITION BY (<column_name> [, ...]))]
172-
;
173-
```
174-
175-
{{% yaml-table data="syntax_options/create_table/create_table_options_source_populated_kafka_protobuf_msg"
176-
%}}
177-
178-
{{</ tab >}}
179-
180-
{{< tab "FORMAT PROTOBUF using CSR" >}}
181-
182-
Creates a read-only table from a [Kafka source](/sql/create-source/), ingesting
183-
messages encoded in PROTOBUF format using the schema information from Confluent
184-
Schema Registry. By default, the table contains the columns specified in the
185-
schema. You can include additional columns using the `INCLUDE` options.
186-
187-
{{< tip >}}
188-
189-
- If your `.proto` file includes a package declaration, you must specify the
190-
fully qualified message name using `FORMAT PROTOBUF MESSAGE` instead of `FORMAT
191-
PROTOBUF using CONFLUENT SCHEMA REGISTRY CONNECTION`.
192-
193-
- If you want to specify an `UPSERT ENVELOPE`, use `KEY FORMAT ... VALUE
194-
FORMAT ...` instead.
195-
196-
{{</ tip >}}
197-
198-
```mzsql
199-
CREATE TABLE <table_name> FROM SOURCE <source_name> [(REFERENCE <ref_object>)]
200-
FORMAT PROTOBUF USING CONFLUENT SCHEMA REGISTRY CONNECTION <conn_name>
201-
[INCLUDE
202-
PARTITION [AS <name>] | OFFSET [AS <name>]
203-
| TIMESTAMP [AS <name>] | HEADERS [AS <name>] | HEADER <key_name> AS <name> [BYTES]
204-
[, ...]
205-
]
206-
[ENVELOPE NONE] -- Default. Uses the append-only envelope.
207-
[WITH (PARTITION BY (<column_name> [, ...]))]
208-
;
209-
```
210-
211-
{{% yaml-table data="syntax_options/create_table/create_table_options_source_populated_kafka_protobuf_csr"
212-
%}}
213-
214-
{{</ tab >}}
215-
216143
{{< tab "FORMAT JSON" >}}
217144

218145
Creates a read-only table from a [Kafka source](/sql/create-source/), where the
@@ -310,8 +237,6 @@ KEY FORMAT <format1> VALUE FORMAT <format2>
310237
-- INLINE <schema> | ID <schema_registry_id> | LATEST ]
311238
-- [VALUE STRATEGY
312239
-- INLINE <schema> | ID <schema_registry_id> | LATEST ]
313-
-- | PROTOBUF USING CONFLUENT SCHEMA REGISTRY CONNECTION <conn_name>
314-
-- | PROTOBUF MESSAGE <msg_name> USING SCHEMA <encoded_schema>
315240
-- | CSV WITH <num> COLUMNS DELIMITED BY <char>
316241
-- | JSON | TEXT | BYTES
317242
[INCLUDE

doc/user/data/syntax_options/create_table/create_table_options_source_populated_kafka.yml

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,8 +51,6 @@ rows:
5151
| Format | Description |
5252
|--------|-------------|
5353
| `AVRO USING CONFLUENT SCHEMA REGISTRY CONNECTION <csr_connection> [KEY STRATEGY <strategy> VALUE STRATEGY <strategy>]` | Decode the data as Avro, specifying the [Confluent Schema Registry connection](/sql/create-connection/#confluent-schema-registry) to use. You can also specify the `KEY STRATEGY` and `VALUE STRATEGY` to use: <table> <thead> <tr> <th>Strategy</th> <th>Description</th> </tr> </thead> <tbody> <tr> <td><code>LATEST</code></td> <td>(Default) Use the latest writer schema from the schema registry as the reader schema.</td> </tr> <tr> <td><code>ID</code></td> <td>Use a specific schema from the registry.</td> </tr> <tr> <td><code>INLINE</code></td> <td>Use the inline schema.</td> </tr> </tbody> </table>|
54-
| `PROTOBUF USING CONFLUENT SCHEMA REGISTRY CONNECTION <csr_connection>` | Decode the data as Protocol Buffers, specifying the [Confluent Schema Registry connection](/sql/create-connection/#confluent-schema-registry) to use. |
55-
| `PROTOBUF MESSAGE <msg_name> USING SCHEMA <encoded_schema>` | Decode the data as Protocol Buffers, specifying the `<msg_name>` and the inline `<encoded_schema>` descriptor to use. |
5654
| `JSON` | Decode the data as JSON. |
5755
| `TEXT` | Decode the data as TEXT. |
5856
| `BYTES` | Decode the data as BYTES. |

doc/user/data/syntax_options/create_table/create_table_options_source_populated_kafka_protobuf_csr.yml

Lines changed: 0 additions & 74 deletions
This file was deleted.

doc/user/data/syntax_options/create_table/create_table_options_source_populated_kafka_protobuf_msg.yml

Lines changed: 0 additions & 85 deletions
This file was deleted.

doc/user/shared-content/kafka-format-envelope-compat-table.md

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,5 @@ The following table specifies the format and envelope compatibility:
33
| Format | Append-only envelope | Upsert envelope | Debezium envelope |
44
|--------|:--------------------:|:---------------:|:-----------------:|
55
| Avro ||||
6-
| Protobuf | ✓ | ✓
76
| JSON/Text/Bytes | ✓ | ✓
87
| CSV || |

0 commit comments

Comments
 (0)