public static void main()

in docker/ops-playground-image/java/flink-playground-clickcountjob/src/main/java/org/apache/flink/playgrounds/ops/clickcount/ClickEventGenerator.java [58:80]

• 14 lines of code
• 2 McCabe index (conditional complexity)

	public static void main(String[] args) throws Exception {

		final ParameterTool params = ParameterTool.fromArgs(args);

		String topic = params.get("topic", "input");

		Properties kafkaProps = createKafkaProperties(params);

		KafkaProducer<byte[], byte[]> producer = new KafkaProducer<>(kafkaProps);

		ClickIterator clickIterator = new ClickIterator();

		while (true) {

			ProducerRecord<byte[], byte[]> record = new ClickEventSerializationSchema(topic).serialize(
					clickIterator.next(),
					null);

			producer.send(record);

			Thread.sleep(DELAY);
		}
	}