This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-connectors-kafka.git
The following commit(s) were added to refs/heads/main by this push:
new 608eb4e0 Add suppress warnings for unchecked conversions (#71)
608eb4e0 is described below
commit 608eb4e087ae050f67ac3542b00eb490d66e747d
Author: Matthew de Detrich <[email protected]>
AuthorDate: Sun May 21 13:28:29 2023 +0200
Add suppress warnings for unchecked conversions (#71)
---
testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java | 1 +
.../org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java | 1 +
.../java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java | 1 +
.../main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java | 1 +
.../java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java | 1 +
5 files changed, 5 insertions(+)
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java
index 9ad75b40..f2b4ccab 100644
--- a/testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java
+++ b/testkit/src/main/java/org/apache/pekko/kafka/testkit/KafkaTest.java
@@ -29,6 +29,7 @@ import org.junit.jupiter.api.BeforeAll;
* of the test class with `@BeforeAll` and `@AfterAll` annotated methods
called by the test
* framework.
*/
+@SuppressWarnings("unchecked")
public abstract class KafkaTest extends BaseKafkaTest {
/**
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java
index 628807ab..1db0271c 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaJunit4Test.java
@@ -30,6 +30,7 @@ import org.junit.Before;
*
* <p>The Testcontainers dependency has to be added explicitly.
*/
+@SuppressWarnings("unchecked")
public abstract class TestcontainersKafkaJunit4Test extends KafkaJunit4Test {
private static final KafkaTestkitTestcontainersSettings settings =
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java
index 48210386..28121fec 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/TestcontainersKafkaTest.java
@@ -31,6 +31,7 @@ import org.apache.pekko.stream.Materializer;
*
* <p>The Testcontainers dependency has to be added explicitly.
*/
+@SuppressWarnings("unchecked")
public abstract class TestcontainersKafkaTest extends KafkaTest {
public static final KafkaTestkitTestcontainersSettings settings =
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java
index 8a5ad22d..524d23d7 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/BaseKafkaTest.java
@@ -46,6 +46,7 @@ import java.util.concurrent.TimeUnit;
import java.util.function.Predicate;
import java.util.stream.IntStream;
+@SuppressWarnings("unchecked")
public abstract class BaseKafkaTest extends KafkaTestKitClass {
public static final int partition0 = 0;
diff --git
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java
index 1b355d27..612b2fa4 100644
---
a/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java
+++
b/testkit/src/main/java/org/apache/pekko/kafka/testkit/javadsl/KafkaJunit4Test.java
@@ -22,6 +22,7 @@ import org.junit.After;
import org.junit.Before;
/** JUnit 4 base-class with some convenience for accessing a Kafka broker. */
+@SuppressWarnings("unchecked")
public abstract class KafkaJunit4Test extends BaseKafkaTest {
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
