Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1649

can not use io.debezium.converters.ByteBufferConverter on docker.io/debezium/connect image

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Not a Bug
    • Icon: Major Major
    • None
    • 1.0.0.Beta3
    • connect-service
    • None

      running docker.io/debezium/connect image.

      When I try to register this connector:

      {
        "name": "paymentscheduler-connector",
        "config": {
            "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
            "tasks.max": "1",
            "database.hostname": "postgres",
            "database.port": "5432",
            "database.user": "postgres",
            "database.password": "mysecretpassword",
            "database.dbname" : "postgres",
            "database.server.name": "paymentschedulerdb",
            "table.whitelist": "paymentscheduler.payment_scheduler_event",
            "plugin.name": "wal2json",
            "key.converter": "org.apache.kafka.connect.json.JsonConverter",
            "value.converter": "io.debezium.converters.ByteBufferConverter",
            "key.converter.schemas.enable":"false",
            "value.converter.schemas.enable": "false",
            "poll.interval.ms": 300,
            "transforms" : "outbox",
            "transforms.outbox.type": "io.debezium.transforms.outbox.EventRouter",
            "transforms.outbox.table.field.event.payload": "event",
            "transforms.outbox.table.field.event.payload.id": "payment_schedule_id",
            "transforms.outbox.table.field.event.type": "event_type",
            "transforms.outbox.route.by.field": "topic",
            "transforms.outbox.route.topic.regex": "(?<routedByValue>.*)",
            "transforms.outbox.route.topic.replacement": "${routedByValue}",
            "transforms.outbox.table.fields.additional.placement": "event_type:header:eventType,correlation_id:header:b3"
        }
      }
      
      

      This error is returned:

      {"error_code":400,"message":"Connector configuration is invalid and contains the following 1 error(s):\nInvalid value io.debezium.converters.ByteBufferConverter for configuration value.converter: Class io.debezium.converters.ByteBufferConverter could not be found.\nYou can also find the above list of errors at the endpoint `/{connectorType}/config/validate`"}
      

      To be able to register the connector, I have added the debezium-core-1.0.0.Beta3.jar on the /kafka/libs.
      It's that normal ?

              Unassigned Unassigned
              deblockthomas62 Thomas Deblock (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: