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

Short field not null throw an exception

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • 0.6.2
    • None
    • mysql-connector
    • None

      MySQL table schema:

      CREATE TABLE TEST_SMALLSHORT (
    ID           INT   PRIMARY KEY,
    FIELD    SMALLINT  NOT NULL
)

      The Kafka Connect schema type is Int16, but JdbcValueConverters#convertSmallInt() may return a an int. This causes the following exception:

      org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type INT16: class java.lang.Integer

              Unassigned Unassigned
              gomax.pan max P (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: