public void start()

in src/main/java/com/amazon/kinesis/kafka/AmazonKinesisSinkConnector.java [104:127]

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

	public void start(Map<String, String> props) {
		region = props.get(REGION);
		streamName = props.get(STREAM_NAME);
		roleARN = props.get(ROLE_ARN);
		roleSessionName = props.get(ROLE_SESSION_NAME);
		roleExternalID = props.get(ROLE_EXTERNAL_ID);
		roleDurationSeconds = props.get(ROLE_DURATION_SECONDS);
		kinesisEndpoint = props.get(KINESIS_ENDPOINT);
		maxBufferedTime = props.get(MAX_BUFFERED_TIME);
		maxConnections = props.get(MAX_CONNECTIONS);
		rateLimit = props.get(RATE_LIMIT);
		ttl = props.get(RECORD_TTL);
		metricsLevel = props.get(METRICS_LEVEL);
		metricsGranuality = props.get(METRICS_GRANUALITY);
		metricsNameSpace = props.get(METRICS_NAMESPACE);
		aggregation = props.get(AGGREGATION_ENABLED);
		usePartitionAsHashKey = props.get(USE_PARTITION_AS_HASH_KEY);
		flushSync = props.get(FLUSH_SYNC);
		singleKinesisProducerPerPartition = props.get(SINGLE_KINESIS_PRODUCER_PER_PARTITION);
		pauseConsumption = props.get(PAUSE_CONSUMPTION);
		outstandingRecordsThreshold = props.get(OUTSTANDING_RECORDS_THRESHOLD);
		sleepPeriod = props.get(SLEEP_PERIOD);
		sleepCycles = props.get(SLEEP_CYCLES);
	}