You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/08/19 00:58:06 UTC
[kafka] branch 2.6 updated: HOTFIX: use Exit.exit instead of
System.exit (#9198)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a commit to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.6 by this push:
new 9b900a6 HOTFIX: use Exit.exit instead of System.exit (#9198)
9b900a6 is described below
commit 9b900a6be2f1c369d12b782cb7b710900ff20550
Author: Matthias J. Sax <ma...@confluent.io>
AuthorDate: Tue Aug 18 17:55:58 2020 -0700
HOTFIX: use Exit.exit instead of System.exit (#9198)
Reviewers: Ismael Juma <is...@confluent.io>, Colin P. McCabe <cm...@apache.org>
---
.../test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java | 7 ++++---
.../test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java | 7 ++++---
.../test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java | 7 ++++---
.../test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java | 7 ++++---
4 files changed, 16 insertions(+), 12 deletions(-)
diff --git a/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java b/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
index 07c7d5d..f280eb0 100644
--- a/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
+++ b/streams/upgrade-system-tests-22/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.kafka.streams.tests;
+import org.apache.kafka.common.utils.Exit;
import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.streams.StreamsConfig;
@@ -40,7 +41,7 @@ public class StreamsSmokeTest {
public static void main(final String[] args) throws IOException {
if (args.length < 2) {
System.err.println("StreamsSmokeTest are expecting two parameters: propFile, command; but only see " + args.length + " parameter");
- System.exit(1);
+ Exit.exit(1);
}
final String propFileName = args[0];
@@ -53,7 +54,7 @@ public class StreamsSmokeTest {
if (kafka == null) {
System.err.println("No bootstrap kafka servers specified in " + StreamsConfig.BOOTSTRAP_SERVERS_CONFIG);
- System.exit(1);
+ Exit.exit(1);
}
if ("process".equals(command)) {
@@ -63,7 +64,7 @@ public class StreamsSmokeTest {
System.err.println("processingGuarantee must be either " + StreamsConfig.AT_LEAST_ONCE + " or " +
StreamsConfig.EXACTLY_ONCE);
- System.exit(1);
+ Exit.exit(1);
}
}
diff --git a/streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java b/streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
index 07c7d5d..f280eb0 100644
--- a/streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
+++ b/streams/upgrade-system-tests-23/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.kafka.streams.tests;
+import org.apache.kafka.common.utils.Exit;
import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.streams.StreamsConfig;
@@ -40,7 +41,7 @@ public class StreamsSmokeTest {
public static void main(final String[] args) throws IOException {
if (args.length < 2) {
System.err.println("StreamsSmokeTest are expecting two parameters: propFile, command; but only see " + args.length + " parameter");
- System.exit(1);
+ Exit.exit(1);
}
final String propFileName = args[0];
@@ -53,7 +54,7 @@ public class StreamsSmokeTest {
if (kafka == null) {
System.err.println("No bootstrap kafka servers specified in " + StreamsConfig.BOOTSTRAP_SERVERS_CONFIG);
- System.exit(1);
+ Exit.exit(1);
}
if ("process".equals(command)) {
@@ -63,7 +64,7 @@ public class StreamsSmokeTest {
System.err.println("processingGuarantee must be either " + StreamsConfig.AT_LEAST_ONCE + " or " +
StreamsConfig.EXACTLY_ONCE);
- System.exit(1);
+ Exit.exit(1);
}
}
diff --git a/streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java b/streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
index 07c7d5d..f280eb0 100644
--- a/streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
+++ b/streams/upgrade-system-tests-24/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.kafka.streams.tests;
+import org.apache.kafka.common.utils.Exit;
import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.streams.StreamsConfig;
@@ -40,7 +41,7 @@ public class StreamsSmokeTest {
public static void main(final String[] args) throws IOException {
if (args.length < 2) {
System.err.println("StreamsSmokeTest are expecting two parameters: propFile, command; but only see " + args.length + " parameter");
- System.exit(1);
+ Exit.exit(1);
}
final String propFileName = args[0];
@@ -53,7 +54,7 @@ public class StreamsSmokeTest {
if (kafka == null) {
System.err.println("No bootstrap kafka servers specified in " + StreamsConfig.BOOTSTRAP_SERVERS_CONFIG);
- System.exit(1);
+ Exit.exit(1);
}
if ("process".equals(command)) {
@@ -63,7 +64,7 @@ public class StreamsSmokeTest {
System.err.println("processingGuarantee must be either " + StreamsConfig.AT_LEAST_ONCE + " or " +
StreamsConfig.EXACTLY_ONCE);
- System.exit(1);
+ Exit.exit(1);
}
}
diff --git a/streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java b/streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
index 07c7d5d..f280eb0 100644
--- a/streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
+++ b/streams/upgrade-system-tests-25/src/test/java/org/apache/kafka/streams/tests/StreamsSmokeTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.kafka.streams.tests;
+import org.apache.kafka.common.utils.Exit;
import org.apache.kafka.common.utils.Utils;
import org.apache.kafka.streams.StreamsConfig;
@@ -40,7 +41,7 @@ public class StreamsSmokeTest {
public static void main(final String[] args) throws IOException {
if (args.length < 2) {
System.err.println("StreamsSmokeTest are expecting two parameters: propFile, command; but only see " + args.length + " parameter");
- System.exit(1);
+ Exit.exit(1);
}
final String propFileName = args[0];
@@ -53,7 +54,7 @@ public class StreamsSmokeTest {
if (kafka == null) {
System.err.println("No bootstrap kafka servers specified in " + StreamsConfig.BOOTSTRAP_SERVERS_CONFIG);
- System.exit(1);
+ Exit.exit(1);
}
if ("process".equals(command)) {
@@ -63,7 +64,7 @@ public class StreamsSmokeTest {
System.err.println("processingGuarantee must be either " + StreamsConfig.AT_LEAST_ONCE + " or " +
StreamsConfig.EXACTLY_ONCE);
- System.exit(1);
+ Exit.exit(1);
}
}