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 <[email protected]>
AuthorDate: Tue Aug 18 17:55:58 2020 -0700
HOTFIX: use Exit.exit instead of System.exit (#9198)
Reviewers: Ismael Juma <[email protected]>, Colin P. McCabe
<[email protected]>
---
.../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);
}
}
