kafka-connect-jdbc-sink
kafka-connect-jdbc-sink copied to clipboard
🐛 [BUG] - JDBC Sink Connector Not Writing to Existing Db2 Table
What happened?
It appears that the connector only works if the target table in Db2 isn't already defined. When attempting to write to an existing Db2 table, it fails to do so.
Steps To Reproduce
- Set up the JDBC sink connector with the IBM supported version.
- Configure it to write to an existing Db2 table.
- Run the connector.
Environment
No response
Anything else?
Upon investigation, it was discovered that the issue may be related to the table.name.format configuration parameter. Using a lowercase schema name caused problems, but changing it to uppercase seemed to prevent the connector from trying to create a new table on startup.
Version
1.0.0 (Default)
Relevant log output
com.ibm.db2.jcc.am.SqlSyntaxErrorException: DB2 SQL Error: SQLCODE=-601, SQLSTATE=42710, SQLERRMC=DB2INST1.COMPANY;TABLE, DRIVER=4.32.28
Code of Conduct
- [X] I agree to follow this project's Code of Conduct