AdamR

[ATLAS-3261] Set kafka user as current principal for Ranger Authorization

6

If lineage message sent to ATLAS_HOOK has non empty "user" value, NotificationHookConsumer.java will set Authentication context to this user, allowing check in Ranger policies by Atlas authorizer. Currently no user...