in src/main/java/com/amazonaws/kda/flink/benchmarking/util/KDSProducerUtil.java [45:53]
public static Iterator<String> createRotatableInteractions(int numInteractions) {
List<String> interactionList = new ArrayList<String>();
for (int i = 0; i < numInteractions; i++) {
String interactionId = UUID.randomUUID().toString();
System.out.printf("Interaction_id: %s \n", interactionId);
interactionList.add(interactionId);
}
return Iterables.cycle(interactionList).iterator();
}