Неверная снежинка.topic2table.map - PullRequest
Новая
       2

Неверная снежинка.topic2table.map

1 голос
/ 06 октября 2019

Может кто-нибудь сказать мне, почему мое snowke.topic2table.map сообщение о том, что мое Snowflake Sink Connector сообщается как недействительное? База данных KAFKA_TEST была создана в Snowflake, и я могу позволить соединителю приемника создать таблицу для меня. Когда я удаляю из конфигурации параметр snowflake.topic2table.map , он работает нормально ... но я хотел бы контролировать имя создаваемой таблицы. Я использую Confluent 5.3.1 и Snowflake Connector 0.50.

[SF_KAFKA_CONNECTOR] Invalid snowflake.topic2table.map config format: snowflake.topic2table.map (com.snowflake.kafka.connector.Utils:417)

Моя конфигурация приемника: 

{                                                                                        
  "name" : "mySnowflakeSink",
  "config":{
    "connector.class" : "com.snowflake.kafka.connector.SnowflakeSinkConnector",
    "tasks.max" : "2",
    "topics" : "sink-sample-data",
    "snowflake.topic2table.map" : "sink-sample-data:sampledata",
    "buffer.count.records" : "5",
    "snowflake.url.name" : "xxxxxx.us-east-1.snowflakecomputing.com",
    "snowflake.user.name" : "JPARDI",
    "snowflake.private.key" : "yyyyyyy",
    "snowflake.private.key.passphrase" : "zzzzzzz",
    "snowflake.database.name" : "KAFKA_TEST",
    "snowflake.schema.name" : "PUBLIC",
    "key.converter" : "org.apache.kafka.connect.storage.StringConverter",
    "value.converter" : "com.snowflake.kafka.connector.records.SnowflakeJsonConverter"
  }                                                                                      
}

1 Ответ

2 голосов
/ 06 октября 2019

Похоже, что это известная проблема в коннекторе Snowflake, исправленная 5 дней назад этим коммитом и еще не выпущенная.

Проблема заключалась в том, что вместо передачи конфигурацииЗначение, которое вы указали, код проанализировал имя самого свойства: snowflake.topic2table.map.

...