public EventBridgeSinkConfig()

in src/main/java/software/amazon/event/kafkaconnector/EventBridgeSinkConfig.java [126:177]
51 lines of code
3 McCabe index (conditional complexity)

  public EventBridgeSinkConfig(final Map<?, ?> originalProps) {
    super(CONFIG_DEF, originalProps);
    this.connectorId = getString(AWS_CONNECTOR_ID_CONFIG);
    this.region = getString(AWS_REGION_CONFIG);
    this.eventBusArn = getString(AWS_EVENTBUS_ARN_CONFIG);
    this.endpointID = getString(AWS_EVENTBUS_GLOBAL_ENDPOINT_ID_CONFIG);
    this.endpointURI = getString(AWS_ENDPOINT_URI_CONFIG);
    this.awsCredentialsProviderClass = getString(AWS_CREDENTIAL_PROVIDER_CLASS);
    this.roleArn = getString(AWS_ROLE_ARN_CONFIG);
    this.externalId = getString(AWS_ROLE_EXTERNAL_ID_CONFIG);
    this.profileName = getString(AWS_PROFILE_NAME_CONFIG);
    this.maxRetries = getInt(AWS_RETRIES_CONFIG);
    this.retriesDelay = getInt(AWS_RETRIES_DELAY_CONFIG);
    this.resources = getList(AWS_EVENTBUS_RESOURCES_CONFIG);
    this.detailTypeMapperClass = getString(AWS_DETAIL_TYPES_MAPPER_CLASS);
    this.timeMapperClass = getString(AWS_TIME_MAPPER_CLASS);
    this.offloadingDefaultS3EndpointURI = getString(AWS_OFFLOADING_DEFAULT_S3_ENDPOINT_URI);
    this.offloadingDefaultS3Bucket = getString(AWS_OFFLOADING_DEFAULT_S3_BUCKET);
    this.offloadingDefaultFieldRef = getString(AWS_OFFLOADING_DEFAULT_FIELDREF);

    var detailTypes = getList(AWS_DETAIL_TYPES_CONFIG);
    if (detailTypes.size() > 1 || detailTypes.get(0).contains(":")) {
      detailTypeByTopic =
          detailTypes.stream()
              .map(item -> item.split(":"))
              .collect(Collectors.toMap(topic -> topic[0], type -> type[1]));
    } else {
      detailType = detailTypes.get(0);
    }
    log.info(
        "EventBridge properties: connectorId={} eventBusArn={} eventBusRegion={} eventBusEndpointURI={} "
            + "eventBusMaxRetries={} eventBusRetriesDelay={} eventBusResources={} "
            + "eventBusEndpointID={} roleArn={} roleSessionName={} roleExternalID={} "
            + "offloadingDefaultS3EndpointURI={} offloadingDefaultS3Bucket={} offloadingDefaultFieldRef={} "
            + "detailTypeMapperClass={} timeMapperClass={}",
        connectorId,
        eventBusArn,
        region,
        endpointURI,
        maxRetries,
        retriesDelay,
        resources,
        endpointID,
        roleArn,
        connectorId,
        externalId,
        offloadingDefaultS3EndpointURI,
        offloadingDefaultS3Bucket,
        offloadingDefaultFieldRef,
        detailTypeMapperClass,
        timeMapperClass);
  }