Skip to content

Conversation

corgy-w
Copy link
Contributor

@corgy-w corgy-w commented Sep 8, 2025

Reference:io.debezium.jdbc.JdbcConnection

    public <T extends DatabaseSchema<TableId>> Object[] rowToArray(Table table, T databaseSchema, ResultSet rs,
                                                                   ColumnUtils.ColumnArray columnArray)
            throws SQLException {
        final Object[] row = new Object[columnArray.getGreatestColumnPosition()];
        for (int i = 0; i < columnArray.getColumns().length; i++) {
            row[columnArray.getColumns()[i].position() - 1] = getColumnValue(rs, i + 1,
                    columnArray.getColumns()[i], table, databaseSchema);
        }
        return row;
    }

set column.include.list =xx

The field order changes, this bug needs to be fixed

Purpose of this pull request

Does this PR introduce any user-facing change?

How was this patch tested?

Check list

@github-actions github-actions bot added the e2e label Sep 24, 2025
@corgy-w corgy-w marked this pull request as ready for review September 24, 2025 18:11
Add e2e test for MySQL CDC with column.include.list feature following
the pattern of testMysqlCdcCheckDataE2e:
- Added SINK_TABLE_COLUMN_INCLUDE constant
- Created testMysqlCdcWithColumnIncludeList test method that clears both
  source and sink tables before running
- Added SQL query methods for column include test (10 specific columns)
- Added upsertDeleteSourceTableColumnInclude helper method
- Created mysqlcdc_to_mysql_with_column_include_list.conf config file

This test verifies that Debezium's column.include.list configuration
works correctly to filter columns during CDC replication.

Co-authored-by: factory-droid[bot] <138933559+factory-droid[bot]@users.noreply.github.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant