chamikaramj commented on code in PR #39717:
URL: https://github.com/apache/beam/pull/39717#discussion_r3787829693
##########
website/www/site/content/en/documentation/io/managed-io.md:
##########
@@ -276,52 +265,85 @@ and Beam SQL is invoked via the Managed API under the
hood.
</tr>
<tr>
<td>
- <strong>table</strong>
+ <strong>bootstrap_servers</strong>
</td>
<td>
<code style="color: green">str</code>
</td>
<td>
- Identifier of the Delta Lake table.
+ A list of host/port pairs to use for establishing the initial
connection to the Kafka cluster. The client will make use of all servers
irrespective of which servers are specified here for bootstrapping—this list
only impacts the initial hosts used to discover the full set of servers. |
Format: host1:port1,host2:port2,...
</td>
</tr>
<tr>
<td>
- hadoop_config
+ <strong>format</strong>
</td>
<td>
- <code>map[<span style="color: green;">str</span>, <span style="color:
green;">str</span>]</code>
+ <code style="color: green">str</code>
</td>
<td>
- Properties passed to the Hadoop Configuration.
+ The encoding format for the data stored in Kafka. Valid options are:
RAW,JSON,AVRO,PROTO
</td>
</tr>
<tr>
<td>
- timestamp
+ <strong>topic</strong>
</td>
<td>
<code style="color: green">str</code>
</td>
<td>
- Timestamp of the Delta Lake table to read.
+ n/a
</td>
</tr>
<tr>
<td>
- version
+ file_descriptor_path
</td>
<td>
- <code style="color: #f54251">int64</code>
+ <code style="color: green">str</code>
</td>
<td>
- Version of the Delta Lake table to read.
+ The path to the Protocol Buffer File Descriptor Set file. This file is
used for schema definition and message serialization.
+ </td>
+ </tr>
+ <tr>
+ <td>
+ message_name
+ </td>
+ <td>
+ <code style="color: green">str</code>
+ </td>
+ <td>
+ The name of the Protocol Buffer message to be used for schema
extraction and data conversion.
+ </td>
+ </tr>
+ <tr>
+ <td>
+ producer_config_updates
+ </td>
+ <td>
+ <code>map[<span style="color: green;">str</span>, <span style="color:
green;">str</span>]</code>
+ </td>
+ <td>
+ A list of key-value pairs that act as configuration parameters for
Kafka producers. Most of these configurations will not be needed, but if you
need to customize your Kafka producer, you may use this. See a detailed list:
https://docs.confluent.io/platform/current/installation/configuration/producer-configs.html
+ </td>
+ </tr>
+ <tr>
+ <td>
+ schema
+ </td>
+ <td>
+ <code style="color: green">str</code>
+ </td>
+ <td>
+ n/a
</td>
</tr>
</table>
</div>
-### `DELTA_CDC` Read
Review Comment:
@Amar3tto do you know why DELTA_CDC docs were reverted here even though
https://github.com/apache/beam/pull/39599 is in the release ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
