возникли проблемы с преобразованием плоского значения - PullRequest
Новая
       7

возникли проблемы с преобразованием плоского значения

0 голосов
/ 28 ноября 2018

Я пытаюсь сгладить тему, прежде чем отправить ее на мою базу данных postgres, используя что-то вроде соединителя ниже.Я использую образ докера kafka connect confluent 4.1.1, единственное изменение, которое я скопировал в файл / usr / share / java нестандартный jar коннектора и запускаю его под другой учетной записью.

версия (kafka connect)«1.1.1-cp1»

commit «0a5db4d59ee15a47» 

{
    "name": "problematic_postgres_sink",
    "config": {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",

        "key.converter": "org.apache.kafka.connect.storage.StringConverter",
        "key.converter.schema.registry.url": "http://kafkaschemaregistry.service.consul:8081",

        "value.converter": "io.confluent.connect.avro.AvroConverter",
        "value.converter.schema.registry.url": "http://kafkaschemaregistry.service.consul:8081",

        "connection.url": "jdbc:postgresql://123.123.123.123:5432/mypostgresdb",
        "connection.user": "abc",
        "connection.password": "xyz",

        "insert.mode": "upsert",
        "auto.create": true,
        "auto.evolve": true,

        "topics": "mytopic",
        "pk.mode": "kafka",

        "transforms": "Flatten",
        "transforms.Flatten.type": "org.apache.kafka.connect.transforms.Flatten$Value",
        "transforms.Flatten.delimiter": "_"
    }
}

Я получаю код ошибки 400:

Конфигурация соединителя недопустима и содержит следующее1 ошибки: недопустимый класс значений org.apache.kafka.connect.transforms.Flatten для конфигурации transforms.Flatten.type: Ошибка при получении определения конфигурации из Transformation: null

...