Skip to content

Commit

Permalink
connectors: Iceberg connector guide
Browse files Browse the repository at this point in the history
  • Loading branch information
bochenekmartin committed Aug 9, 2023
1 parent 81bb903 commit e5013d1
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 15 deletions.
6 changes: 3 additions & 3 deletions backend/pkg/connector/guide/iceberg_sink.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,12 +38,12 @@ func NewIcebergSinkGuide(opts ...Option) Guide {
{
ConfigKeys: []string{
"iceberg.catalog.type",
"iceberg.catalog.s3.endpoint",
"iceberg.catalog.s3.access-key-id",
"iceberg.catalog.s3.secret-access-key",
"iceberg.catalog.client.region",
"iceberg.catalog.s3.endpoint",
"iceberg.catalog.s3.path-style-access",
"iceberg.catalog.s3.endpoint",
"iceberg.catalog.s3.access-key-id",
"iceberg.catalog.s3.secret-access-key",
},
},
},
Expand Down
24 changes: 12 additions & 12 deletions backend/pkg/connector/interceptor/iceberg_sink_hook.go
Original file line number Diff line number Diff line change
Expand Up @@ -60,8 +60,8 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con
DefaultValue: "",
Importance: model.ConfigDefinitionImportanceHigh,
Required: true,
DisplayName: "iceberg.catalog.s3.secret-access-key",
Documentation: "iceberg.catalog.s3.secret-access-key",
DisplayName: "Iceberg catalog S3 Secret Access Key",
Documentation: "",
Dependents: []string{},
},
Value: model.ConfigDefinitionValue{
Expand All @@ -78,10 +78,10 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con
Name: "iceberg.catalog.s3.access-key-id",
Type: "STRING",
DefaultValue: "",
Importance: model.ConfigDefinitionImportanceHigh,
Importance: model.ConfigDefinitionImportanceMedium,
Required: true,
DisplayName: "iceberg.catalog.s3.access-key-id",
Documentation: "iceberg.catalog.s3.access-key-id",
DisplayName: "Iceberg catalog S3 access key id",
Documentation: "",
Dependents: []string{},
},
Value: model.ConfigDefinitionValue{
Expand All @@ -100,8 +100,8 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con
DefaultValue: "",
Importance: model.ConfigDefinitionImportanceHigh,
Required: true,
DisplayName: "iceberg.catalog.s3.endpoint",
Documentation: "iceberg.catalog.s3.endpoint",
DisplayName: "Iceberg catalog S3 endpoint",
Documentation: "",
Dependents: []string{},
},
Value: model.ConfigDefinitionValue{
Expand All @@ -119,8 +119,8 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con
DefaultValue: "",
Importance: model.ConfigDefinitionImportanceHigh,
Required: true,
DisplayName: "iceberg.catalog.s3.path-style-access",
Documentation: "iceberg.catalog.s3.path-style-access",
DisplayName: "Iceberg catalog S3 path style access",
Documentation: "",
Dependents: []string{},
},
Value: model.ConfigDefinitionValue{
Expand All @@ -138,8 +138,8 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con
DefaultValue: "",
Importance: model.ConfigDefinitionImportanceHigh,
Required: true,
DisplayName: "iceberg.catalog.client.region",
Documentation: "iceberg.catalog.client.region",
DisplayName: "Iceberg catalog client region",
Documentation: "",
Dependents: []string{},
},
Value: model.ConfigDefinitionValue{
Expand All @@ -158,7 +158,7 @@ func KafkaConnectToConsoleIcebergSinkHook(response model.ValidationResponse, con
Importance: model.ConfigDefinitionImportanceHigh,
Required: true,
DisplayName: "Iceberg catalog credential",
Documentation: "Iceberg catalog credential",
Documentation: "",
Dependents: []string{},
},
Value: model.ConfigDefinitionValue{
Expand Down

0 comments on commit e5013d1

Please sign in to comment.