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: