[NOJIRA] feat: refactor build script for multiproject

build.gradle.kts

@@ -48,9 +48,10 @@ java {
     withSourcesJar()
 }
 
-tasks.wrapper {
+tasks.withType<Wrapper> {
     doFirst {
-        val sha256Sum = URL("$distributionUrl.sha256").readText()
+        val sha256Sum = uri("$distributionUrl.sha256").toURL().readText()
+
         propertiesFile.appendText("distributionSha256Sum=${sha256Sum}\n")
         println("Added checksum to wrapper properties")
     }
@@ -59,7 +60,7 @@ tasks.wrapper {
 
 checkstyle {
     toolVersion = "10.16.0"
-    configDirectory.set(rootProject.file("checkstyle/"))
+    configDirectory.set(project.projectDir.resolve("checkstyle/"))
 }
 
 jacoco {

src/main/java/io/aiven/connect/jdbc/sink/BufferedRecords.java

@@ -243,7 +243,7 @@ private void verifySuccessfulExecutions(final int totalSuccessfulExecutionCount,
         }
 
         if (successNoInfo) {
-            log.info("{} {} records:{} , but no count of the number of rows it affected is available",
+            log.debug("{} {} records:{} , but no count of the number of rows it affected is available",
                     config.insertMode,
                     recordType,
                     batchRecords.size()
@@ -296,13 +296,13 @@ private boolean isTombstone(final SinkRecord record) {
     }
 
     public void close() throws SQLException {
-        log.info("Closing BufferedRecords with preparedStatement: {}", preparedStatement);
+        log.debug("Closing BufferedRecords with preparedStatement: {}", preparedStatement);
         if (preparedStatement != null) {
             preparedStatement.close();
             preparedStatement = null;
         }
 
-        log.info("Closing BufferedRecords with deletePreparedStatement: {}", deletePreparedStatement);
+        log.debug("Closing BufferedRecords with deletePreparedStatement: {}", deletePreparedStatement);
         if (deletePreparedStatement != null) {
             deletePreparedStatement.close();
             deletePreparedStatement = null;

src/main/java/io/aiven/connect/jdbc/sink/DbStructure.java

@@ -102,7 +102,7 @@ void create(
             );
         }
         final String sql = dbDialect.buildCreateTableStatement(tableId, fieldsMetadata.allFields.values());
-        log.info("Creating table with sql: {}", sql);
+        log.debug("Creating table with sql: {}", sql);
         dbDialect.applyDdlStatements(connection, Collections.singletonList(sql));
     }
 
@@ -159,7 +159,7 @@ boolean amendIfNecessary(
         }
 
         final List<String> amendTableQueries = dbDialect.buildAlterTable(tableId, missingFields);
-        log.info(
+        log.debug(
                 "Amending table to add missing fields:{} maxRetries:{} with SQL: {}",
                 missingFields,
                 maxRetries,
@@ -231,7 +231,7 @@ Set<SinkRecordField> missingFields(
         }
 
         if (missingFieldsIgnoreCase.size() > 0) {
-            log.info(
+            log.debug(
                     "Unable to find fields {} among column names {}",
                     missingFieldsIgnoreCase,
                     dbColumnNames

src/main/java/io/aiven/connect/jdbc/sink/JdbcDbWriter.java

@@ -57,7 +57,7 @@ public class JdbcDbWriter {
         this.cachedConnectionProvider = new CachedConnectionProvider(this.dbDialect) {
             @Override
             protected void onConnect(final Connection connection) throws SQLException {
-                log.info("JdbcDbWriter Connected");
+                log.debug("JdbcDbWriter Connected");
                 connection.setAutoCommit(false);
             }
         };

src/main/java/io/aiven/connect/jdbc/source/JdbcSourceTask.java

@@ -82,7 +82,7 @@ public String version() {
 
     @Override
     public void start(final Map<String, String> properties) {
-        log.info("Starting JDBC source task");
+        log.debug("Starting JDBC source task");
         try {
             config = new JdbcSourceTaskConfig(properties);
             config.validate();
@@ -100,7 +100,7 @@ public void start(final Map<String, String> properties) {
             final String connectionUrl = config.getConnectionUrl();
             dialect = DatabaseDialects.findBestFor(connectionUrl, config);
         }
-        log.info("Using JDBC dialect {}", dialect.name());
+        log.debug("Using JDBC dialect {}", dialect.name());
 
         cachedConnectionProvider = new SourceConnectionProvider(dialect, maxConnAttempts, retryBackoff);
 
@@ -253,7 +253,7 @@ public void start(final Map<String, String> properties) {
         }
 
         running.set(true);
-        log.info("Started JDBC source task");
+        log.debug("Started JDBC source task");
     }
 
     //This method returns a list of possible partition maps for different offset protocols
@@ -268,7 +268,7 @@ private List<Map<String, String>> possibleTablePartitions(final String table) {
 
     @Override
     public void stop() throws ConnectException {
-        log.info("Stopping JDBC source task");
+        log.debug("Stopping JDBC source task");
         running.set(false);
         // Wait for any in-progress polls to stop before closing resources
         // On older versions of Kafka Connect, SourceTask::stop and SourceTask::poll may
@@ -281,7 +281,7 @@ public void stop() throws ConnectException {
     }
 
     protected void closeResources() {
-        log.info("Closing resources for JDBC source task");
+        log.debug("Closing resources for JDBC source task");
         try {
             if (cachedConnectionProvider != null) {
                 cachedConnectionProvider.close();

src/main/java/io/aiven/connect/jdbc/source/TableMonitorThread.java

@@ -194,7 +194,7 @@ private synchronized boolean updateTables() {
         }
 
         if (!newTables.equals(this.tables)) {
-            log.info(
+            log.debug(
                 "After filtering the tables are: {}",
                 dialect.expressionBuilder()
                     .appendList()

src/main/java/io/aiven/connect/jdbc/util/CachedConnectionProvider.java

@@ -87,7 +87,7 @@ private void newConnection() throws SQLException {
         while (attempts < maxConnectionAttempts) {
             try {
                 ++count;
-                log.info("Attempting to open connection #{} to {}", count, provider);
+                log.debug("Attempting to open connection #{} to {}", count, provider);
                 connection = provider.getConnection();
                 onConnect(connection);
                 return;
@@ -113,7 +113,7 @@ private void newConnection() throws SQLException {
     public synchronized void close() {
         if (connection != null) {
             try {
-                log.info("Closing connection #{} to {}", count, provider);
+                log.debug("Closing connection #{} to {}", count, provider);
                 connection.close();
             } catch (final SQLException sqle) {
                 log.warn("Ignoring error closing connection", sqle);

src/main/java/io/aiven/connect/jdbc/util/TableDefinitions.java

@@ -63,7 +63,7 @@ public TableDefinition get(
             if (dialect.tableExists(connection, tableId)) {
                 dbTable = dialect.describeTable(connection, tableId);
                 if (dbTable != null) {
-                    log.info("Setting metadata for table {} to {}", tableId, dbTable);
+                    log.debug("Setting metadata for table {} to {}", tableId, dbTable);
                     cache.put(tableId, dbTable);
                 }
             }
@@ -84,7 +84,7 @@ public TableDefinition refresh(
         final TableId tableId
     ) throws SQLException {
         final TableDefinition dbTable = dialect.describeTable(connection, tableId);
-        log.info("Refreshing metadata for table {} to {}", tableId, dbTable);
+        log.debug("Refreshing metadata for table {} to {}", tableId, dbTable);
         cache.put(dbTable.id(), dbTable);
         return dbTable;
     }