Merge pull request #1252 from redpanda-data/mb/snowflake-converters-a…

…vro-json connectors: added json and avro converters to snowflake connector
redpanda-data · May 10, 2024 · 08363a3 · 08363a3
2 parents 4024bf9 + 9564a0b
commit 08363a3
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/backend/pkg/connector/patch/snowflake_sink.go b/backend/pkg/connector/patch/snowflake_sink.go
@@ -58,6 +58,8 @@ func (*ConfigPatchSnowflake) PatchDefinition(d model.ConfigDefinition, _ string)
 			AddRecommendedValueWithMetadata("com.snowflake.kafka.connector.records.SnowflakeJsonConverter", "SNOWFLAKE_JSON").
 			AddRecommendedValueWithMetadata("com.snowflake.kafka.connector.records.SnowflakeAvroConverter", "SNOWFLAKE_AVRO").
 			AddRecommendedValueWithMetadata("com.snowflake.kafka.connector.records.SnowflakeAvroConverterWithoutSchemaRegistry", "SNOWFLAKE_AVRO_WITHOUT_SCHEMA_REGISTRY").
+			AddRecommendedValueWithMetadata("io.confluent.connect.avro.AvroConverter", "AVRO").
+			AddRecommendedValueWithMetadata("org.apache.kafka.connect.json.JsonConverter", "JSON").
 			AddRecommendedValueWithMetadata("org.apache.kafka.connect.storage.StringConverter", "STRING").
 			AddRecommendedValueWithMetadata("com.redpanda.connectors.converter.protobuf.ProtobufConverter", "PROTOBUF").
 			SetDefaultValue("com.snowflake.kafka.connector.records.SnowflakeJsonConverter")