[flink-connector-kafka] branch main updated: [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters (#30)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guoweijie pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git


The following commit(s) were added to refs/heads/main by this push:
     new 22446880 [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters (#30)
22446880 is described below

commit 224468804f4cfb4a293102b8b596a299463dc077
Author: Weijie Guo <re...@163.com>
AuthorDate: Thu May 25 16:36:28 2023 +0800

    [FLINK-32172][kafka] KafkaExampleUtils incorrect check of the minimum number of parameters (#30)
---
 .../org/apache/flink/streaming/kafka/test/base/KafkaExampleUtil.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-kafka-e2e-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaExampleUtil.java b/flink-connector-kafka-e2e-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaExampleUtil.java
index 2d05380b..a6fa83e6 100644
--- a/flink-connector-kafka-e2e-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaExampleUtil.java
+++ b/flink-connector-kafka-e2e-tests/flink-streaming-kafka-test-base/src/main/java/org/apache/flink/streaming/kafka/test/base/KafkaExampleUtil.java
@@ -27,7 +27,7 @@ public class KafkaExampleUtil {
     public static StreamExecutionEnvironment prepareExecutionEnv(ParameterTool parameterTool)
             throws Exception {
 
-        if (parameterTool.getNumberOfParameters() < 5) {
+        if (parameterTool.getNumberOfParameters() < 4) {
             System.out.println(
                     "Missing parameters!\n"
                             + "Usage: Kafka --input-topic <topic> --output-topic <topic> "