Run import with IMPORT INTO <schema_name>.<table_name> FROM SCRIPT KAFKA_CONSUMER WITH ... ❌
If required: create connection with IDENTIFIED BY 'SSL_KEY_PASSWORD=<PASSWORD>;SSL_KEYSTORE_PASSWORD=<SSLPASSWORD>;SSL_KEYSTORE_LOCATION=/buckets/bfsdefault/<BUCKET>/keystore.jks;SSL_TRUSTSTORE_PASSWORD=<TRUSTSTOREPASS>;SSL_TRUSTSTORE_LOCATION=/buckets/bfsdefault/<BUCKET>/truststore.jks' ❌
In order to support the extension mananger we need to add an extension that manages the Kafka connector.
Steps for installation
See user guide:
KAFKA_PARTITION DECIMAL(18, 0), KAFKA_OFFSET DECIMAL(36, 0)❌IMPORT INTO <schema_name>.<table_name> FROM SCRIPT KAFKA_CONSUMER WITH ...❌IDENTIFIED BY 'SSL_KEY_PASSWORD=<PASSWORD>;SSL_KEYSTORE_PASSWORD=<SSLPASSWORD>;SSL_KEYSTORE_LOCATION=/buckets/bfsdefault/<BUCKET>/keystore.jks;SSL_TRUSTSTORE_PASSWORD=<TRUSTSTOREPASS>;SSL_TRUSTSTORE_LOCATION=/buckets/bfsdefault/<BUCKET>/truststore.jks'❌