You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2024/03/18 10:43:47 UTC
(camel) 03/06: CAMEL-20563: shutdown existing consumer instance to release resources… (#13510)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.4.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 932da7bbb842ea42b9d19edc4acf09d742ae5dfd
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Mar 18 11:33:33 2024 +0100
CAMEL-20563: shutdown existing consumer instance to release resources… (#13510)
---
.../kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
index 81d8f603044..cae054b82d1 100644
--- a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
+++ b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/integration/KafkaBreakOnFirstErrorReleaseResourcesIT.java
@@ -49,7 +49,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
@EnabledOnOs(value = { OS.LINUX, OS.MAC, OS.FREEBSD, OS.OPENBSD, OS.WINDOWS },
architectures = { "amd64", "aarch64", "s390x" },
disabledReason = "This test does not run reliably on ppc64le")
-class KafkaBreakOnFirstErrorReleaseResourcesIT extends BaseKafkaTestSupport {
+class KafkaBreakOnFirstErrorReleaseResourcesIT extends BaseEmbeddedKafkaTestSupport {
public static final String ROUTE_ID = "breakOnFirstError-20563";
public static final String TOPIC = "breakOnFirstError-20563";