[ https://issues.apache.org/jira/browse/KAFKA-2849?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15008926#comment-15008926 ]
ASF GitHub Bot commented on KAFKA-2849: --------------------------------------- Github user ijuma closed the pull request at: https://github.com/apache/kafka/pull/541 > Pass `KafkaChannel.principal` to `RequestChannel.Session` > --------------------------------------------------------- > > Key: KAFKA-2849 > URL: https://issues.apache.org/jira/browse/KAFKA-2849 > Project: Kafka > Issue Type: Bug > Components: security > Reporter: Ismael Juma > Assignee: Ismael Juma > > The current code does: > {code} > val session = RequestChannel.Session(new > KafkaPrincipal(KafkaPrincipal.USER_TYPE, channel.principal().getName), > channel.socketDescription) > {code} > It looks to me like we should just pass `channel.principal`. > cc [~parth.brahmbhatt] -- This message was sent by Atlassian JIRA (v6.3.4#6332)