Skip to content

Commit

Permalink
See open-metadata/OpenMetadata@4af9764 from refs/heads/main
Browse files Browse the repository at this point in the history
  • Loading branch information
open-metadata committed Jan 16, 2025
1 parent 572b5c5 commit 55f9995
Show file tree
Hide file tree
Showing 8 changed files with 128 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,14 @@

The sourceConfig is defined [here](https://github.com/open-metadata/OpenMetadata/blob/main/openmetadata-spec/src/main/resources/json/schema/metadataIngestion/messagingServiceMetadataPipeline.json):

**generateSampleData:** Option to turn on/off generating sample data during metadata extraction.
- **generateSampleData:** Option to turn on/off generating sample data during metadata extraction.

**topicFilterPattern:** Note that the `topicFilterPattern` supports regex as include or exclude.
- **topicFilterPattern:** Note that the `topicFilterPattern` supports regex as include or exclude.

- **generateSampleData:** Option to turn on/off generating sample data during metadata extraction. `generateSampleData` supports boolean value either `true` or `false`.

- **markDeletedTopics:** Optional configuration to soft delete topics in OpenMetadata if the source topics are deleted. Also, if the topic is deleted, all the associated entities like sample data, lineage, etc., with that topic will be deleted. `markDeletedTopics` supports boolean value either `true` or `false`.

- **overrideMetadata:** Set the 'Override Metadata' toggle to control whether to override the existing metadata in the OpenMetadata server with the metadata fetched from the source. If the toggle is set to true, the metadata fetched from the source will override the existing metadata in the OpenMetadata server. If the toggle is set to false, the metadata fetched from the source will not override the existing metadata in the OpenMetadata server. This is applicable for fields like description, tags, owner and displayName. `overrideMetadata` supports boolean value either `true` or `false`.

{% /codeInfo %}
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,8 @@
# includes:
# - topic1
# generateSampleData: true
# generateSampleData: false # true
# markDeletedTopics: true # false
# overrideMetadata: false # true

```
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,14 @@

The sourceConfig is defined [here](https://github.com/open-metadata/OpenMetadata/blob/main/openmetadata-spec/src/main/resources/json/schema/metadataIngestion/messagingServiceMetadataPipeline.json):

**generateSampleData:** Option to turn on/off generating sample data during metadata extraction.
- **generateSampleData:** Option to turn on/off generating sample data during metadata extraction.

**topicFilterPattern:** Note that the `topicFilterPattern` supports regex as include or exclude.
- **topicFilterPattern:** Note that the `topicFilterPattern` supports regex as include or exclude.

- **generateSampleData:** Option to turn on/off generating sample data during metadata extraction. `generateSampleData` supports boolean value either `true` or `false`.

- **markDeletedTopics:** Optional configuration to soft delete topics in OpenMetadata if the source topics are deleted. Also, if the topic is deleted, all the associated entities like sample data, lineage, etc., with that topic will be deleted. `markDeletedTopics` supports boolean value either `true` or `false`.

- **overrideMetadata:** Set the 'Override Metadata' toggle to control whether to override the existing metadata in the OpenMetadata server with the metadata fetched from the source. If the toggle is set to true, the metadata fetched from the source will override the existing metadata in the OpenMetadata server. If the toggle is set to false, the metadata fetched from the source will not override the existing metadata in the OpenMetadata server. This is applicable for fields like description, tags, owner and displayName. `overrideMetadata` supports boolean value either `true` or `false`.

{% /codeInfo %}
Original file line number Diff line number Diff line change
Expand Up @@ -8,4 +8,8 @@
# includes:
# - topic1
# generateSampleData: true
# generateSampleData: false # true
# markDeletedTopics: true # false
# overrideMetadata: false # true

```
28 changes: 28 additions & 0 deletions content/v1.6.x/connectors/messaging/kafka/yaml.md
Original file line number Diff line number Diff line change
Expand Up @@ -122,6 +122,22 @@ following [link](https://docs.confluent.io/platform/current/clients/confluent-ka

{% /codeInfo %}

{% codeInfo srNumber=9 %}
**securityProtocol**: security.protocol consumer config property. It accepts `PLAINTEXT`,`SASL_PLAINTEXT`, `SASL_SSL`, `SSL`.
{% /codeInfo %}

{% codeInfo srNumber=10 %}
**schemaRegistryTopicSuffixName**: Schema Registry Topic Suffix Name. The suffix to be appended to the topic name to get topic schema from registry.
{% /codeInfo %}

{% codeInfo srNumber=11 %}
**schemaRegistrySSL**: Schema Registry SSL Config. Configuration for enabling SSL for the Schema Registry connection.
{% /codeInfo %}

{% codeInfo srNumber=12 %}
**supportsMetadataExtraction**: Supports Metadata Extraction. `supportsMetadataExtraction` supports boolean value either true or false.
{% /codeInfo %}

{% partial file="/v1.6/connectors/yaml/messaging/source-config-def.md" /%}

{% partial file="/v1.6/connectors/yaml/ingestion-sink-def.md" /%}
Expand Down Expand Up @@ -164,6 +180,18 @@ source:
```yaml {% srNumber=8 %}
schemaRegistryConfig: {}
```
```yaml {% srNumber=9 %}
# securityProtocol: PLAINTEXT
```
```yaml {% srNumber=10 %}
# schemaRegistryTopicSuffixName: -value
```
```yaml {% srNumber=11 %}
# schemaRegistrySSL: ""
```
```yaml {% srNumber=12 %}
# supportsMetadataExtraction: true
```

{% partial file="/v1.6/connectors/yaml/messaging/source-config.md" /%}

Expand Down
15 changes: 15 additions & 0 deletions content/v1.6.x/connectors/messaging/redpanda/yaml.md
Original file line number Diff line number Diff line change
Expand Up @@ -117,6 +117,14 @@ following [link](https://docs.confluent.io/platform/current/clients/confluent-ka

{% /codeInfo %}

{% codeInfo srNumber=9 %}
**securityProtocol**: security.protocol consumer config property. It accepts `PLAINTEXT`,`SASL_PLAINTEXT`, `SASL_SSL`, `SSL`.
{% /codeInfo}

{% codeInfo srNumber=10 %}
**supportsMetadataExtraction**: Supports Metadata Extraction. `supportsMetadataExtraction` supports boolean value either true or false.
{% /codeInfo %}

{% partial file="/v1.6/connectors/yaml/messaging/source-config-def.md" /%}

{% partial file="/v1.6/connectors/yaml/ingestion-sink-def.md" /%}
Expand Down Expand Up @@ -159,6 +167,13 @@ source:
```yaml {% srNumber=8 %}
schemaRegistryConfig: {}
```
```yaml {% srNumber=9 %}
# securityProtocol: PLAINTEXT
```
```yaml {% srNumber=10 %}
# supportsMetadataExtraction: true
```


{% partial file="/v1.6/connectors/yaml/messaging/source-config.md" /%}

Expand Down
46 changes: 37 additions & 9 deletions content/v1.7.x-SNAPSHOT/connectors/messaging/kafka/yaml.md
Original file line number Diff line number Diff line change
Expand Up @@ -19,13 +19,13 @@ Configure and schedule Kafka metadata and profiler workflows from the OpenMetada
- [Metadata Ingestion](#metadata-ingestion)
- [Enable Security](#securing-kafka-connection-with-ssl-in-openmetadata)

{% partial file="/v1.7/connectors/external-ingestion-deployment.md" /%}
{% partial file="/v1.6/connectors/external-ingestion-deployment.md" /%}

## Requirements

### Python Requirements

{% partial file="/v1.7/connectors/python-requirements.md" /%}
{% partial file="/v1.6/connectors/python-requirements.md" /%}

To run the Kafka ingestion, you will need to install:

Expand Down Expand Up @@ -122,11 +122,27 @@ following [link](https://docs.confluent.io/platform/current/clients/confluent-ka

{% /codeInfo %}

{% partial file="/v1.7/connectors/yaml/messaging/source-config-def.md" /%}
{% codeInfo srNumber=9 %}
**securityProtocol**: security.protocol consumer config property. It accepts `PLAINTEXT`,`SASL_PLAINTEXT`, `SASL_SSL`, `SSL`.
{% /codeInfo %}

{% codeInfo srNumber=10 %}
**schemaRegistryTopicSuffixName**: Schema Registry Topic Suffix Name. The suffix to be appended to the topic name to get topic schema from registry.
{% /codeInfo %}

{% codeInfo srNumber=11 %}
**schemaRegistrySSL**: Schema Registry SSL Config. Configuration for enabling SSL for the Schema Registry connection.
{% /codeInfo %}

{% codeInfo srNumber=12 %}
**supportsMetadataExtraction**: Supports Metadata Extraction. `supportsMetadataExtraction` supports boolean value either true or false.
{% /codeInfo %}

{% partial file="/v1.6/connectors/yaml/messaging/source-config-def.md" /%}

{% partial file="/v1.7/connectors/yaml/ingestion-sink-def.md" /%}
{% partial file="/v1.6/connectors/yaml/ingestion-sink-def.md" /%}

{% partial file="/v1.7/connectors/yaml/workflow-config-def.md" /%}
{% partial file="/v1.6/connectors/yaml/workflow-config-def.md" /%}

{% /codeInfoContainer %}

Expand Down Expand Up @@ -164,12 +180,24 @@ source:
```yaml {% srNumber=8 %}
schemaRegistryConfig: {}
```
```yaml {% srNumber=9 %}
# securityProtocol: PLAINTEXT
```
```yaml {% srNumber=10 %}
# schemaRegistryTopicSuffixName: -value
```
```yaml {% srNumber=11 %}
# schemaRegistrySSL: ""
```
```yaml {% srNumber=12 %}
# supportsMetadataExtraction: true
```

{% partial file="/v1.7/connectors/yaml/messaging/source-config.md" /%}
{% partial file="/v1.6/connectors/yaml/messaging/source-config.md" /%}

{% partial file="/v1.7/connectors/yaml/ingestion-sink.md" /%}
{% partial file="/v1.6/connectors/yaml/ingestion-sink.md" /%}

{% partial file="/v1.7/connectors/yaml/workflow-config.md" /%}
{% partial file="/v1.6/connectors/yaml/workflow-config.md" /%}

{% /codeBlock %}

Expand All @@ -186,4 +214,4 @@ To establish secure connections between OpenMetadata and Kafka, in the `YAML` yo
sslKey: "/path/to/your/ssl_key"
```
{% partial file="/v1.7/connectors/yaml/ingestion-cli.md" /%}
{% partial file="/v1.6/connectors/yaml/ingestion-cli.md" /%}
33 changes: 24 additions & 9 deletions content/v1.7.x-SNAPSHOT/connectors/messaging/redpanda/yaml.md
Original file line number Diff line number Diff line change
Expand Up @@ -18,13 +18,13 @@ Configure and schedule Redpanda metadata and profiler workflows from the OpenMet
- [Requirements](#requirements)
- [Metadata Ingestion](#metadata-ingestion)

{% partial file="/v1.7/connectors/external-ingestion-deployment.md" /%}
{% partial file="/v1.6/connectors/external-ingestion-deployment.md" /%}

## Requirements

### Python Requirements

{% partial file="/v1.7/connectors/python-requirements.md" /%}
{% partial file="/v1.6/connectors/python-requirements.md" /%}

To run the Redpanda ingestion, you will need to install:

Expand Down Expand Up @@ -117,11 +117,19 @@ following [link](https://docs.confluent.io/platform/current/clients/confluent-ka

{% /codeInfo %}

{% partial file="/v1.7/connectors/yaml/messaging/source-config-def.md" /%}
{% codeInfo srNumber=9 %}
**securityProtocol**: security.protocol consumer config property. It accepts `PLAINTEXT`,`SASL_PLAINTEXT`, `SASL_SSL`, `SSL`.
{% /codeInfo}

{% partial file="/v1.7/connectors/yaml/ingestion-sink-def.md" /%}
{% codeInfo srNumber=10 %}
**supportsMetadataExtraction**: Supports Metadata Extraction. `supportsMetadataExtraction` supports boolean value either true or false.
{% /codeInfo %}

{% partial file="/v1.6/connectors/yaml/messaging/source-config-def.md" /%}

{% partial file="/v1.6/connectors/yaml/ingestion-sink-def.md" /%}

{% partial file="/v1.7/connectors/yaml/workflow-config-def.md" /%}
{% partial file="/v1.6/connectors/yaml/workflow-config-def.md" /%}

{% /codeInfoContainer %}

Expand Down Expand Up @@ -159,15 +167,22 @@ source:
```yaml {% srNumber=8 %}
schemaRegistryConfig: {}
```
```yaml {% srNumber=9 %}
# securityProtocol: PLAINTEXT
```
```yaml {% srNumber=10 %}
# supportsMetadataExtraction: true
```


{% partial file="/v1.7/connectors/yaml/messaging/source-config.md" /%}
{% partial file="/v1.6/connectors/yaml/messaging/source-config.md" /%}

{% partial file="/v1.7/connectors/yaml/ingestion-sink.md" /%}
{% partial file="/v1.6/connectors/yaml/ingestion-sink.md" /%}

{% partial file="/v1.7/connectors/yaml/workflow-config.md" /%}
{% partial file="/v1.6/connectors/yaml/workflow-config.md" /%}

{% /codeBlock %}

{% /codePreview %}

{% partial file="/v1.7/connectors/yaml/ingestion-cli.md" /%}
{% partial file="/v1.6/connectors/yaml/ingestion-cli.md" /%}

0 comments on commit 55f9995

Please sign in to comment.