diff --git a/backend/pkg/connector/guide/iceberg_sink.go b/backend/pkg/connector/guide/iceberg_sink.go index cbbeda2c5..19c265f62 100644 --- a/backend/pkg/connector/guide/iceberg_sink.go +++ b/backend/pkg/connector/guide/iceberg_sink.go @@ -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", }, }, }, diff --git a/backend/pkg/connector/interceptor/iceberg_sink_hook.go b/backend/pkg/connector/interceptor/iceberg_sink_hook.go index a160f06b7..06dbe1c8f 100644 --- a/backend/pkg/connector/interceptor/iceberg_sink_hook.go +++ b/backend/pkg/connector/interceptor/iceberg_sink_hook.go @@ -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{ @@ -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{ @@ -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{ @@ -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{ @@ -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{ @@ -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{