Ismael Juma created KAFKA-2849:
----------------------------------
Summary: 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
Fix For: 0.9.0.0
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)
