databricks / iceberg-kafka-connect

Apache License 2.0
219 stars 49 forks source link

Support HDFS config and custom Hadoop properties #68

Closed bryanck closed 1 year ago

bryanck commented 1 year ago

This PR updates the method for creating a Hadoop config so it first attempts to instantiate an HdfsConfiguration if it is available (which loads hdfs-site.xml and core-site.xml on the classpath). If the class is not available, then the method will fall back to Configuration which only loads core-site.xml on the classpath. Furthermore, additional Hadoop config properties can be set in the connector config, by prefixing them with iceberg.hadoop.. The readme section on configuration was updated to reflect this.