You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@ranger.apache.org by Nikhil P <ni...@gmail.com> on 2018/03/23 12:50:58 UTC

Review Request 66245: Ranger Kafka default policy creation improvement

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/
-----------------------------------------------------------

Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.


Bugs: RANGER-2029
    https://issues.apache.org/jira/browse/RANGER-2029


Repository: ranger


Description
-------

Ranger Kafka default policy creation improvement.


Diffs
-----

  plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 


Diff: https://reviews.apache.org/r/66245/diff/1/


Testing
-------

1) Tested if required policies are getting created when required service configs are given.


Thanks,

Nikhil P


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Madhan Neethiraj <ma...@apache.org>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/#review199935
-----------------------------------------------------------



@Nikhil - consider updating RangerBaseService to allow custom default policies to be specified via service-configurations as shown below. All services can benefit from this approach.

default-policy.1.name=ATLAS_HOOK
default-policy.1.resource.topic=ATLAS_HOOK
default-policy.1.policyItem.1.users=hive,hbase
default-policy.1.policyItem.1.groups=
default-policy.1.policyItem.1.accessTypes=publish
default-policy.1.policyItem.2.users=atlas
default-policy.1.policyItem.2.groups=
default-policy.1.policyItem.2.accessTypes=consume

default-policy.2.name=ATLAS_HOOK
default-policy.2.resource.topic=ATLAS_HOOK
default-policy.2.policyItem.1.users=atlas
default-policy.2.policyItem.1.accessTypes=publish
default-policy.2.policyItem.2.users=rangertagsync
default-policy.2.policyItem.2.accessTypes=consume

- Madhan Neethiraj


On March 23, 2018, 12:50 p.m., Nikhil P wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/66245/
> -----------------------------------------------------------
> 
> (Updated March 23, 2018, 12:50 p.m.)
> 
> 
> Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.
> 
> 
> Bugs: RANGER-2029
>     https://issues.apache.org/jira/browse/RANGER-2029
> 
> 
> Repository: ranger
> 
> 
> Description
> -------
> 
> Ranger Kafka default policy creation improvement.
> 
> 
> Diffs
> -----
> 
>   plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 
> 
> 
> Diff: https://reviews.apache.org/r/66245/diff/1/
> 
> 
> Testing
> -------
> 
> 1) Tested if required policies are getting created when required service configs are given.
> 
> 
> Thanks,
> 
> Nikhil P
> 
>


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Qiang Zhang <zh...@zte.com.cn>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/#review200343
-----------------------------------------------------------




plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java
Lines 117 (patched)
<https://reviews.apache.org/r/66245/#comment281063>

    Did you test this function carefully?


- Qiang Zhang


On April 3, 2018, 7:21 a.m., Nikhil P wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/66245/
> -----------------------------------------------------------
> 
> (Updated April 3, 2018, 7:21 a.m.)
> 
> 
> Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.
> 
> 
> Bugs: RANGER-2029
>     https://issues.apache.org/jira/browse/RANGER-2029
> 
> 
> Repository: ranger
> 
> 
> Description
> -------
> 
> Ranger Kafka default policy creation improvement.
> 
> 
> Diffs
> -----
> 
>   agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java d99f478 
>   plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 
> 
> 
> Diff: https://reviews.apache.org/r/66245/diff/3/
> 
> 
> Testing
> -------
> 
> 1) Tested if required policies are getting created when required service configs are given.
> 
> 
> Thanks,
> 
> Nikhil P
> 
>


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Mehul Parikh <me...@freestoneinfotech.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/#review200641
-----------------------------------------------------------


Ship it!




Ship It!

- Mehul Parikh


On April 3, 2018, 7:21 a.m., Nikhil P wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/66245/
> -----------------------------------------------------------
> 
> (Updated April 3, 2018, 7:21 a.m.)
> 
> 
> Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.
> 
> 
> Bugs: RANGER-2029
>     https://issues.apache.org/jira/browse/RANGER-2029
> 
> 
> Repository: ranger
> 
> 
> Description
> -------
> 
> Ranger Kafka default policy creation improvement.
> 
> 
> Diffs
> -----
> 
>   agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java d99f478 
>   plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 
> 
> 
> Diff: https://reviews.apache.org/r/66245/diff/3/
> 
> 
> Testing
> -------
> 
> 1) Tested if required policies are getting created when required service configs are given.
> 
> 
> Thanks,
> 
> Nikhil P
> 
>


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Velmurugan Periasamy <vp...@hortonworks.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/#review200638
-----------------------------------------------------------


Ship it!




Ship It!

- Velmurugan Periasamy


On April 3, 2018, 7:21 a.m., Nikhil P wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/66245/
> -----------------------------------------------------------
> 
> (Updated April 3, 2018, 7:21 a.m.)
> 
> 
> Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.
> 
> 
> Bugs: RANGER-2029
>     https://issues.apache.org/jira/browse/RANGER-2029
> 
> 
> Repository: ranger
> 
> 
> Description
> -------
> 
> Ranger Kafka default policy creation improvement.
> 
> 
> Diffs
> -----
> 
>   agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java d99f478 
>   plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 
> 
> 
> Diff: https://reviews.apache.org/r/66245/diff/3/
> 
> 
> Testing
> -------
> 
> 1) Tested if required policies are getting created when required service configs are given.
> 
> 
> Thanks,
> 
> Nikhil P
> 
>


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Nikhil P <ni...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/
-----------------------------------------------------------

(Updated April 3, 2018, 12:51 p.m.)


Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.


Bugs: RANGER-2029
    https://issues.apache.org/jira/browse/RANGER-2029


Repository: ranger


Description
-------

Ranger Kafka default policy creation improvement.


Diffs (updated)
-----

  agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java d99f478 
  plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 


Diff: https://reviews.apache.org/r/66245/diff/3/

Changes: https://reviews.apache.org/r/66245/diff/2-3/


Testing
-------

1) Tested if required policies are getting created when required service configs are given.


Thanks,

Nikhil P


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Madhan Neethiraj <ma...@apache.org>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/#review200295
-----------------------------------------------------------




agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java
Lines 136 (patched)
<https://reviews.apache.org/r/66245/#comment280985>

    Hardcoding max of "3" policies doesn't look right. Instead, I would suggest to retrieve all defined indexes by scanning the configs - as shown below:
    
    if (additionalDefaultPolicySetup) {
      final String PROP_POLICY_NAME_PREFIX = "policy.";
      final String PROP_POLICY_NAME_SUFFIX = ".name";
    
      List<String> policyIndexes = new ArrayList<>();
    
      for (String configName : configs.keySet()) {
        if (configName.startsWith(PROP_POLICY_NAME_PREFIX) && configName.endsWith(PROP_POLICY_NAME_SUFFIX)) {
          policyIndexes.add(configName.substring(PROP_POLICY_NAME_PREFIX.length(), configName.length() - PROP_POLICY_NAME_SUFFIX.length());
        }
      }
    
      for (String policyIndex : policyIndexes) {
        String                            propertyPrefix  = "policy." + policyIndex + ".resource.";
        Map<String, RangerPolicyResource> policyResources = getResourcesForPrefix(resourcePropertyPrefix);
    
    	if (MapUtils.isNotEmpty(policyResources()){
          // ...
        }
      }
    }


- Madhan Neethiraj


On April 2, 2018, 9:04 a.m., Nikhil P wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/66245/
> -----------------------------------------------------------
> 
> (Updated April 2, 2018, 9:04 a.m.)
> 
> 
> Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.
> 
> 
> Bugs: RANGER-2029
>     https://issues.apache.org/jira/browse/RANGER-2029
> 
> 
> Repository: ranger
> 
> 
> Description
> -------
> 
> Ranger Kafka default policy creation improvement.
> 
> 
> Diffs
> -----
> 
>   agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java d99f478 
>   plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 
> 
> 
> Diff: https://reviews.apache.org/r/66245/diff/2/
> 
> 
> Testing
> -------
> 
> 1) Tested if required policies are getting created when required service configs are given.
> 
> 
> Thanks,
> 
> Nikhil P
> 
>


Re: Review Request 66245: Ranger Kafka default policy creation improvement

Posted by Nikhil P <ni...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/66245/
-----------------------------------------------------------

(Updated April 2, 2018, 2:34 p.m.)


Review request for ranger, Ankita Sinha, Don Bosco Durai, Gautam Borad, Abhay Kulkarni, Madhan Neethiraj, Pradeep Agrawal, Ramesh Mani, Selvamohan Neethiraj, Sailaja Polavarapu, and Velmurugan Periasamy.


Bugs: RANGER-2029
    https://issues.apache.org/jira/browse/RANGER-2029


Repository: ranger


Description
-------

Ranger Kafka default policy creation improvement.


Diffs (updated)
-----

  agents-common/src/main/java/org/apache/ranger/plugin/service/RangerBaseService.java d99f478 
  plugin-kafka/src/main/java/org/apache/ranger/services/kafka/RangerServiceKafka.java b7bbe98 


Diff: https://reviews.apache.org/r/66245/diff/2/

Changes: https://reviews.apache.org/r/66245/diff/1-2/


Testing
-------

1) Tested if required policies are getting created when required service configs are given.


Thanks,

Nikhil P