src/main/java/com/amazonaws/kda/flink/benchmarking/util/KDSProducerUtil.java (1 line): - line 150: // TODO: For simplicity, the backoff implemented as a constant 100ms sleep