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

Outbox Router documentation outdated regarding value converter

XMLWordPrintable

    • False
    • None
    • False

      What Debezium connector do you use and what version?

      Debezium PostgreSQL 2.x

      What is the connector configuration?

      For Outbox Router

      What is the captured database version and mode of depoyment?

      PostgreSQL 13

      What behaviour do you expect?

      Documentation showing updated information about binary converter. The right converter to use is `io.debezium.converters.BinaryDataConverter` instead of `io.debezium.converters.ByteBufferConverter`.

      What behaviour do you see?

      Documentation pointing to now completely removed `ByteBufferConverter`. If the connector configuration is not updated before trying to upgrade Debezium in Kafka Connect, Kafka Connect will simply fail to start.

      Do you see the same behaviour using the latest released Debezium version?

      yes

      Do you have the connector logs, ideally from start till finish?

      [2022-10-25 20:45:49,632] ERROR Stopping due to error (org.apache.kafka.connect.cli.ConnectDistributed)
      org.apache.kafka.common.config.ConfigException: Invalid value io.debezium.converters.ByteBufferConverter for configuration value.converter: Class io.debezium.converters.ByteBufferConverter could not be found.
          at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:744)
          at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:490)
          at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483)
          at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:113)
          at org.apache.kafka.common.config.AbstractConfig.<init>(AbstractConfig.java:133)
          at org.apache.kafka.connect.runtime.WorkerConfig.<init>(WorkerConfig.java:366)
          at org.apache.kafka.connect.runtime.distributed.DistributedConfig.<init>(DistributedConfig.java:405)
          at org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:95)
          at org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:80)

              Unassigned Unassigned
              enzo.cappa Enzo Cappa
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

                Created:
                Updated:
                Resolved: