java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleAggregatorProducer.java [79:84]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		System.out.println("Creating " + ProducerConfig.RECORDS_TO_TRANSMIT + " records...");
		for (int i = 1; i <= ProducerConfig.RECORDS_TO_TRANSMIT; i++) {
			String pk = ProducerUtils.randomPartitionKey();
			String ehk = ProducerUtils.randomExplicitHashKey();
			byte[] data = ProducerUtils.randomData(i, ProducerConfig.RECORD_SIZE_BYTES);
			try {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



java/KinesisTestProducers/src/main/java/com/amazonaws/kinesis/producer/SampleAggregatorProducer.java [102:110]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		System.out.println("Creating " + ProducerConfig.RECORDS_TO_TRANSMIT + " records...");
		for (int i = 1; i <= ProducerConfig.RECORDS_TO_TRANSMIT; i++) {
			String pk = ProducerUtils.randomPartitionKey();
			String ehk = ProducerUtils.randomExplicitHashKey();
			byte[] data = ProducerUtils.randomData(i, ProducerConfig.RECORD_SIZE_BYTES);

			// addUserRecord returns non-null when a full record is ready to
			// transmit
			try {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -