public void startAsync()

in src/main/java/software/amazon/event/kafkaconnector/util/StatusReporter.java [38:45]

• 8 lines of code
• 1 McCabe index (conditional complexity)

  public void startAsync() {
    log.info("Starting status reporter");
    scheduler.scheduleAtFixedRate(
        () -> log.info("Total records sent={}", totalRecordsSent.get()),
        interval,
        interval,
        timeUnit);
  }