Iceberg Sink Connector with Snowflake Catalog

Kafka Connect
1

Is an Iceberg Sink Connector configurable with a Snowflake Catalog? Tried two approaches following the GitHub page: iceberg-kafka-connect/README.md at main · tabular-io/iceberg-kafka-connect · GitHub

1) Set iceberg catalog type equal to Snowflake
Configuration Attempt: “iceberg.catalog.type”:“snowflake”
Error: "java.lang.UnsupportedOperationException: Unknown catalog type: snowflake

2) Set iceberg catalog impelementation equal to the SnowflakeCatalogue class in the Apache Iceberg library
Configuration Attempt: “iceberg.catalog.catalog-impl”:“org.apache.iceberg.snowflake.SnowflakeCatalog”
Error: “Cannot find constructor for interface org.apache.iceberg.catalog.Catalog”

  • Does this mean the Iceberg Sink Connector doesn’t contain all classes & constructors from the Apache Iceberg library?
  • Class in Apache Iceberg library: SnowflakeCatalog

Any other recommended approaches, or am I doing something wrong with either of the current approaches? Thanks

2

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.