public void stop()

in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkTask.java [169:178]

• 9 lines of code
• 3 McCabe index (conditional complexity)

  public void stop() {
    log.trace("Stopping sink task");
    if (eventBridgeWriter != null) {
      eventBridgeWriter.shutDownEventBridgeClient();
    }

    if (statusReporter.isRunning()) {
      statusReporter.stopAsync();
    }
  }