This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 6d2493c18eaa0b53571a0f2cbe722a89359bdf17 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Jan 13 15:05:22 2021 +0100 Fixed invalid usage of raw types --- .../kafkaconnector/common/services/kafkaconnect/KafkaConnectRunner.java | 2 +- .../org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCITCase.java | 2 +- .../camel/kafkaconnector/jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java | 2 +- .../org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java | 2 +- .../apache/camel/kafkaconnector/sql/source/CamelSourceSQLITCase.java | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunner.java b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunner.java index c068fe4..d626c44 100644 --- a/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunner.java +++ b/tests/itests-common/src/test/java/org/apache/camel/kafkaconnector/common/services/kafkaconnect/KafkaConnectRunner.java @@ -216,7 +216,7 @@ class KafkaConnectRunner { public void stop() { if (connect != null) { LOG.info("Removing topics used during the test"); - KafkaClient kafkaClient = new KafkaClient(bootstrapServer); + KafkaClient<?, ?> kafkaClient = new KafkaClient<>(bootstrapServer); for (String connector : herder.connectors()) { herder.connectorActiveTopics(connector).topics().forEach(t -> kafkaClient.deleteTopic(t)); diff --git a/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCITCase.java b/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCITCase.java index 0d6bb8e..4e74e51 100644 --- a/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCITCase.java +++ b/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCITCase.java @@ -63,7 +63,7 @@ public class CamelSinkJDBCITCase extends AbstractKafkaTest { static { final String postgresImage = "postgres:9.6.2"; - JdbcDatabaseContainer container = new PostgreSQLContainer(postgresImage) + JdbcDatabaseContainer<?> container = new PostgreSQLContainer<>(postgresImage) .withDatabaseName("camel") .withUsername("ckc") .withPassword("ckcDevel123") diff --git a/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java b/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java index 73876d3..f678239 100644 --- a/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java +++ b/tests/itests-jdbc/src/test/java/org/apache/camel/kafkaconnector/jdbc/sink/CamelSinkJDBCNoDataSourceITCase.java @@ -62,7 +62,7 @@ public class CamelSinkJDBCNoDataSourceITCase extends AbstractKafkaTest { static { final String postgresImage = "postgres:9.6.2"; - JdbcDatabaseContainer container = new PostgreSQLContainer(postgresImage) + JdbcDatabaseContainer<?> container = new PostgreSQLContainer<>(postgresImage) .withDatabaseName("camel") .withUsername("ckc") .withPassword("ckcDevel123") diff --git a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java index 1d75fa2..ece0c24 100644 --- a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java +++ b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/sink/CamelSinkSQLITCase.java @@ -59,7 +59,7 @@ public class CamelSinkSQLITCase extends AbstractKafkaTest { private int received; public CamelSinkSQLITCase() { - JdbcDatabaseContainer container = new PostgreSQLContainer("postgres:9.6.2") + JdbcDatabaseContainer<?> container = new PostgreSQLContainer<>("postgres:9.6.2") .withDatabaseName("camel") .withUsername("ckc") .withPassword("ckcDevel123") diff --git a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/source/CamelSourceSQLITCase.java b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/source/CamelSourceSQLITCase.java index aab7045..05d6ae4 100644 --- a/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/source/CamelSourceSQLITCase.java +++ b/tests/itests-sql/src/test/java/org/apache/camel/kafkaconnector/sql/source/CamelSourceSQLITCase.java @@ -52,7 +52,7 @@ public class CamelSourceSQLITCase extends AbstractKafkaTest { private int received; public CamelSourceSQLITCase() { - JdbcDatabaseContainer container = new PostgreSQLContainer("postgres:9.6.2") + JdbcDatabaseContainer<?> container = new PostgreSQLContainer<>("postgres:9.6.2") .withDatabaseName("camel") .withUsername("ckc") .withPassword("ckcDevel123")
