Version 0.31.0 with VECTOR support

pom.xml

@@ -4,7 +4,7 @@
 
     <groupId>io.debezium</groupId>
     <artifactId>mysql-binlog-connector-java</artifactId>
-    <version>0.30.0</version>
+    <version>0.31.0</version>
 
     <name>mysql-binlog-connector-java</name>
     <description>MySQL Binary Log connector</description>

src/main/java/com/github/shyiko/mysql/binlog/event/TableMapEventMetadata.java

@@ -37,6 +37,7 @@ public class TableMapEventMetadata implements EventData {
     private DefaultCharset enumAndSetDefaultCharset;
     private List<Integer> enumAndSetColumnCharsets;
     private BitSet visibility;
+    private List<Integer> vectorDimensionality;
 
     public BitSet getSignedness() {
         return signedness;
@@ -134,6 +135,14 @@ public void setVisibility(BitSet visibility) {
         this.visibility = visibility;
     }
 
+    public List<Integer> getVectorDimensionality() {
+        return vectorDimensionality;
+    }
+
+    public void setVectorDimensionality(List<Integer> vectorDimensionality) {
+        this.vectorDimensionality = vectorDimensionality;
+    }
+
     @Override
     public String toString() {
         final StringBuilder sb = new StringBuilder();

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/AbstractRowsEventDataDeserializer.java

@@ -197,6 +197,8 @@ protected Serializable deserializeCell(ColumnType type, int meta, int length, By
                 return deserializeGeometry(meta, inputStream);
             case JSON:
                 return deserializeJson(meta, inputStream);
+            case VECTOR:
+                return deserializeVector(meta, inputStream);
             default:
                 throw new IOException("Unsupported type " + type);
         }
@@ -403,6 +405,11 @@ protected Serializable deserializeBlob(int meta, ByteArrayInputStream inputStrea
         return inputStream.read(blobLength);
     }
 
+    protected Serializable deserializeVector(int meta, ByteArrayInputStream inputStream) throws IOException {
+        int vectorLength = inputStream.readInteger(meta);
+        return inputStream.read(vectorLength);
+    }
+
     protected Serializable deserializeEnum(int length, ByteArrayInputStream inputStream) throws IOException {
         return inputStream.readInteger(length);
     }

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/ColumnType.java

@@ -45,6 +45,7 @@ public enum ColumnType {
     TIMESTAMP_V2(17),
     DATETIME_V2(18),
     TIME_V2(19),
+    VECTOR(242),
     JSON(245),
     NEWDECIMAL(246),
     ENUM(247),

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventDataDeserializer.java

@@ -109,6 +109,7 @@ private int[] readMetadata(ByteArrayInputStream inputStream, byte[] columnTypes)
                 case BLOB:
                 case JSON:
                 case GEOMETRY:
+                case VECTOR:
                     metadata[i] = inputStream.readInteger(1);
                     break;
                 case BIT:

src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java

@@ -128,6 +128,9 @@ public TableMapEventMetadata deserialize(ByteArrayInputStream inputStream, int n
                 case VISIBILITY:
                     result.setVisibility(readBooleanList(inputStream, nColumns));
                     break;
+                case VECTOR_DIMENSIONALITY:
+                    result.setVectorDimensionality(readIntegers(inputStream));
+                    break;
                 default:
                     inputStream.enterBlock(remainingBytes);
                     throw new IOException("Unsupported table metadata field type " + code);
@@ -212,6 +215,7 @@ private enum MetadataFieldType {
         ENUM_AND_SET_DEFAULT_CHARSET(10),   // Charsets of ENUM and SET columns
         ENUM_AND_SET_COLUMN_CHARSET(11),    // Charsets of ENUM and SET columns
         VISIBILITY(12),                     // Column visibility (8.0.23 and newer)
+        VECTOR_DIMENSIONALITY(13),          // Vector column dimensionality (9.0.0 and newer)
         UNKNOWN_METADATA_FIELD_TYPE(
             128);   // Returned with binlog-row-metadata=FULL from MySQL 8.0 in some cases