void startInternal()

in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkTask.java [58:64]

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

  void startInternal(
      EventBridgeSinkConfig config, EventBridgeWriter eventBridgeWriter, ErrantRecordReporter dlq) {
    this.config = config;
    this.eventBridgeWriter = eventBridgeWriter;
    this.dlq = dlq;
    statusReporter.startAsync();
  }