This is an automated email from the ASF dual-hosted git repository.
lianetm pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from c16c240bd1f KAFKA-18688: Fix uniform homogeneous assignor stability
(#19677)
add c60c83aaba3 KAFKA-18847: Refactor OAuth layer to improve reusability
1/N (#19622)
No new revisions were added by this update.
Summary of changes:
.../OAuthBearerLoginCallbackHandler.java | 76 +++++++--------
.../OAuthBearerValidatorCallbackHandler.java | 51 +++++-----
.../secured/AccessTokenValidatorFactory.java | 73 --------------
...TokenValidator.java => BrokerJwtValidator.java} | 20 ++--
...TokenValidator.java => ClientJwtValidator.java} | 12 +--
...rieverFactory.java => DefaultJwtRetriever.java} | 63 ++++++++----
.../internals/secured/DefaultJwtValidator.java | 108 +++++++++++++++++++++
...leTokenRetriever.java => FileJwtRetriever.java} | 10 +-
...ssTokenRetriever.java => HttpJwtRetriever.java} | 38 +++-----
.../oauthbearer/internals/secured/Initable.java | 5 +-
...AccessTokenRetriever.java => JwtRetriever.java} | 10 +-
...AccessTokenValidator.java => JwtValidator.java} | 20 ++--
.../internals/secured/RefreshingHttpsJwks.java | 4 +-
.../internals/secured/ValidateException.java | 2 +-
.../secured/VerificationKeyResolverFactory.java | 2 +-
.../OAuthBearerLoginCallbackHandlerTest.java | 108 +++++++++------------
.../OAuthBearerValidatorCallbackHandlerTest.java | 96 ++++++++++++++----
.../secured/AccessTokenValidatorFactoryTest.java | 73 --------------
...idatorTest.java => BrokerJwtValidatorTest.java} | 10 +-
...idatorTest.java => ClientJwtValidatorTest.java} | 6 +-
...ctoryTest.java => DefaultJwtRetrieverTest.java} | 75 +++++++++++---
.../internals/secured/DefaultJwtValidatorTest.java | 61 ++++++++++++
...etrieverTest.java => HttpJwtRetrieverTest.java} | 62 ++++++------
...kenValidatorTest.java => JwtValidatorTest.java} | 22 ++---
.../internals/secured/OAuthBearerTest.java | 24 ++---
.../apache/kafka/tools/OAuthCompatibilityTool.java | 37 ++++---
26 files changed, 595 insertions(+), 473 deletions(-)
delete mode 100644
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenValidatorFactory.java
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{ValidatorAccessTokenValidator.java
=> BrokerJwtValidator.java} (93%)
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{LoginAccessTokenValidator.java
=> ClientJwtValidator.java} (90%)
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{AccessTokenRetrieverFactory.java
=> DefaultJwtRetriever.java} (68%)
create mode 100644
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/DefaultJwtValidator.java
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{FileTokenRetriever.java
=> FileJwtRetriever.java} (83%)
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{HttpAccessTokenRetriever.java
=> HttpJwtRetriever.java} (94%)
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{AccessTokenRetriever.java
=> JwtRetriever.java} (88%)
rename
clients/src/main/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{AccessTokenValidator.java
=> JwtValidator.java} (80%)
delete mode 100644
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/AccessTokenValidatorFactoryTest.java
rename
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{ValidatorAccessTokenValidatorTest.java
=> BrokerJwtValidatorTest.java} (89%)
rename
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{LoginAccessTokenValidatorTest.java
=> ClientJwtValidatorTest.java} (76%)
rename
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{AccessTokenRetrieverFactoryTest.java
=> DefaultJwtRetrieverTest.java} (56%)
create mode 100644
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/DefaultJwtValidatorTest.java
rename
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{HttpAccessTokenRetrieverTest.java
=> HttpJwtRetrieverTest.java} (73%)
rename
clients/src/test/java/org/apache/kafka/common/security/oauthbearer/internals/secured/{AccessTokenValidatorTest.java
=> JwtValidatorTest.java} (80%)
