@Test(expected = KafkaException.class)
public void buildThrowException() {

	OAuthBearerTokenJwt jwt = new OAuthBearerTokenJwt("token", 1, 1, "User");
	Mockito.when(saslAuthenticationContext.server()).thenReturn(null);
	CustomPrincipal customPrincipal = customPrincipalBuilder.build(saslAuthenticationContext);
}