[
https://issues.apache.org/jira/browse/FLINK-32172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17726109#comment-17726109
]
Weijie Guo edited comment on FLINK-32172 at 5/25/23 1:04 PM:
-------------------------------------------------------------
master(1.18) via 366d01d08601d8cc42fd3ba74aa754a63503ed34.
release-1.17 via 83da3560584f8d95de0acbe2e922b7f327fec7ec.
release-1.16 via a5851984e9f282897c627a668d1b3d1acf48e50d.
flink-connector-kafka via 224468804f4cfb4a293102b8b596a299463dc077.
was (Author: weijie guo):
master(1.18) via 366d01d08601d8cc42fd3ba74aa754a63503ed34.
flink-connector-kafka via 224468804f4cfb4a293102b8b596a299463dc077.
> 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: Longfeng Xu
> Assignee: Weijie Guo
> Priority: Not a Priority
> Fix For: 1.18.0
>
> 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)
