in src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java [71:81]
public void closeConnection() {
if (connection != null) {
try {
connection.close();
} catch (SQLException e) {
LOG.warn("JDBC connection close failed.", e);
} finally {
connection = null;
}
}
}