amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisOptions.java [150:158]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		Properties properties = new Properties();

		for (Map.Entry<String, String> entry : tableOptions.entrySet()) {
			String sourceKey = entry.getKey();
			String sourceVal = entry.getValue();

			if (!TABLE_LEVEL_OPTIONS.contains(sourceKey)) {
				if (sourceKey.startsWith(AWS_PROPERTIES_PREFIX)) {
					properties.put(translateAwsKey(sourceKey), sourceVal);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



amazon-kinesis-connector-flink/src/main/java/software/amazon/kinesis/connectors/flink/table/KinesisOptions.java [170:178]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
		Properties properties = new Properties();

		for (Map.Entry<String, String> entry : tableOptions.entrySet()) {
			String sourceKey = entry.getKey();
			String sourceVal = entry.getValue();

			if (!TABLE_LEVEL_OPTIONS.contains(sourceKey)) {
				if (sourceKey.startsWith(AWS_PROPERTIES_PREFIX)) {
					properties.put(translateAwsKey(sourceKey), sourceVal);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -