public void start()

in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkTask.java [39:56]

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

  public void start(Map<String, String> properties) {
    log.info("Starting Kafka Connect task for EventBridgeSinkConnector");

    var config = new EventBridgeSinkConfig(properties);
    var eventBridgeWriter = new EventBridgeWriter(config);

    ErrantRecordReporter dlq;
    try {
      dlq = context.errantRecordReporter();
    } catch (NoSuchMethodError | NoClassDefFoundError e) {
      dlq = null;
    }
    if (dlq != null) {
      log.info("Dead-letter queue enabled");
    }

    startInternal(config, eventBridgeWriter, dlq);
  }