[ https://issues.apache.org/jira/browse/FLINK-32172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725622#comment-17725622 ]
Weijie Guo edited comment on FLINK-32172 at 5/24/23 3:32 AM: ------------------------------------------------------------- Thanks for the report, this should be an accidental mistake(the minimum parameter count should be 4 instead of 5). It will be fixed asap. was (Author: weijie guo): Thanks for the report, this should be an accidental typo (the minimum parameter count should be 4 instead of 5). It will be fixed asap. > KafkaExample can not run with args > ---------------------------------- > > Key: FLINK-32172 > URL: https://issues.apache.org/jira/browse/FLINK-32172 > Project: Flink > Issue Type: Bug > Components: Connectors / Kafka > Affects Versions: 1.17.0 > Environment: * win11 > * Git > * Maven (we recommend version 3.8.6) > * Java 11 > Reporter: xulongfeng > Assignee: Weijie Guo > Priority: Not a Priority > Attachments: args.png, kafkaexample.png > > > i fork and clone flink-connector-kafka repo. after build and package, i run > org/apache/flink/streaming/kafka/test/KafkaExample.java main() but failed, > comment say: > Example usage: --input-topic test-input --output-topic test-output > --bootstrap.servers > * localhost:9092 --group.id myconsumer > > but console print: Missing parameters! from KafkaExampleUtil where need 5 > paramters but we have 4 > > thank you for your attention to this matter -- This message was sent by Atlassian Jira (v8.20.10#820010)