io.strimzi.kafka.oauth.server

Class OAuthKafkaPrincipal

java.lang.Object

org.apache.kafka.common.security.auth.KafkaPrincipal

io.strimzi.kafka.oauth.server.OAuthKafkaPrincipal

All Implemented Interfaces:

java.security.Principal

public final class OAuthKafkaPrincipal
extends org.apache.kafka.common.security.auth.KafkaPrincipal

This class extends the KafkaPrincipal object to store additional info obtained at session authentication time, and required later by a custom authorizer. Any additional fields should not be included in equals / hashcode check. If they are, that will break re-authentication.

Field Summary

Fields inherited from class org.apache.kafka.common.security.auth.KafkaPrincipal

ANONYMOUS, USER_TYPE

Constructor Summary

Constructors

Constructor and Description
OAuthKafkaPrincipal(java.lang.String principalType, java.lang.String name)
OAuthKafkaPrincipal(java.lang.String principalType, java.lang.String name, BearerTokenWithPayload jwt)

Method Summary

Modifier and Type	Method and Description
BearerTokenWithPayload	getJwt()
java.lang.String	toString()

Methods inherited from class org.apache.kafka.common.security.auth.KafkaPrincipal

equals, fromString, getName, getPrincipalType, hashCode, tokenAuthenticated, tokenAuthenticated

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.security.Principal

implies

Constructor Detail

OAuthKafkaPrincipal

public OAuthKafkaPrincipal(java.lang.String principalType,
                           java.lang.String name)

OAuthKafkaPrincipal

public OAuthKafkaPrincipal(java.lang.String principalType,
                           java.lang.String name,
                           BearerTokenWithPayload jwt)

Method Detail

getJwt

public BearerTokenWithPayload getJwt()

toString

public java.lang.String toString()

Specified by:

toString in interface java.security.Principal

Overrides:

toString in class org.apache.kafka.common.security.auth.KafkaPrincipal