java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleAggregatorProducer.java [113:128]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    ForkJoinPool.commonPool().execute(() -> {
                        sendRecord(producer, streamName, aggRecord);
                    });
                }
            }
            catch (Exception e) {
                e.printStackTrace();
                System.err.println("Failed to add user record: " + e.getMessage());
            }
		}

		flushAndFinish(producer, streamName, aggregator);
	}

	public static void main(String[] args) {
		if (args.length != 2) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleAggregatorProducerKCLCompliant.java [88:103]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    ForkJoinPool.commonPool().execute(() -> {
                        sendRecord(producer, streamName, aggRecord);
                    });
                }
            }
            catch (Exception e) {
                e.printStackTrace();
                System.err.println("Failed to add user record: " + e.getMessage());
            }
		}

		flushAndFinish(producer, streamName, aggregator);
	}

	public static void main(String[] args) {
		if (args.length != 2) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -