A simple parameterized Kafka Producer in Apache Flink
A parametrized Kafka producer in Apache Flink for Input class
Parameters
args[0]: inputTopic
args[1]: inputTopicGroupID
args[2]: datasetPath
args[3]: workers
args[4]: sourcePartition
Input
String value
String key-worker
Long timestamp