При подключении к внутреннему этапу Snowflake я вижу, что он подключается к другому db

Я подключаюсь через недавно выпущенный разъем Snowflake Kafka в автономном режиме. Коннектор может успешно подключиться к моей учетной записи снежинки, но когда он ищет создание внутренней стадии, он не использует правильную базу данных, как в конфигурации

Это содержимое нового файла connector.properties:

name=kafkaSnowNow

connector.class=com.snowflake.kafka.connector.SnowflakeSinkConnector

tasks.max=8

topics=kafkaSnow1,kafkaSnow2

snowflake.topic2table.map= kafkaSnow1:kafka_db.kafka_schema.kafkaSnow1,kafkaSnow2:kafka_db.kafka_schema.kafkaSnow2

buffer.count.records=100

buffer.flush.time=60

buffer.size.bytes=65536

snowflake.url.name=https://xyz.ap-southeast-2.snowflakecomputing.com:443

snowflake.user.name=xyz_user

snowflake.private.key=

snowflake.database.name=kafka_db

snowflake.schema.name=kafka_schema

key.converter=org.apache.kafka.connect.storage.StringConverter

value.converter=com.snowflake.kafka.connector.records.SnowflakeJsonConverter

Когда я запускаю коннектор, делается попытка записи записей, но ищет этап ниже.

desc stage
identifier(SNOWFLAKE_KAFKA_CONNECTOR_kafkaSnowNow_STAGE_kafka_db.kafka_schema.kafkaSnow1)

snowflake-cloud-data-platform apache-kafka-connect
person Rachel McGuigan    schedule 13.12.2019    source источник
comment
Совершенно уверен, что это будет лучше всего поднять в репозитории github: github.com/snowflakedb/ snowflake-kafka-connector / issues   -  person Robin Moffatt    schedule 16.12.2019
comment
Согласен, у меня возникли проблемы с восстановлением контакта с пользователем Snowflake, но я указал им на это, когда они вернутся к своему первоначальному вопросу. @RobinMoffatt большое спасибо за направление.   -  person Rachel McGuigan    schedule 17.12.2019