This is an automated email from the ASF dual-hosted git repository.
sriharsha pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 7334222 KAFKA-8412: Fix nullpointer exception thrown on flushing
before closing producers (#7207)
add d08bcae KAFKA-8669: Add security providers in kafka security config
(#7090)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/admin/AdminClientConfig.java | 12 +++++
.../kafka/clients/consumer/ConsumerConfig.java | 14 ++++-
.../kafka/clients/producer/ProducerConfig.java | 12 +++++
.../config/{Config.java => SecurityConfig.java} | 18 +++----
.../common/security/SecurityProviderCreator.java | 27 +++++-----
.../security/authenticator/LoginManager.java | 2 +
.../common/security/ssl/SslEngineBuilder.java | 4 +-
.../kafka/common/security/ssl/SslFactory.java | 23 ++++++--
.../apache/kafka/common/utils/SecurityUtils.java | 31 +++++++++++
.../kafka/common/network/SslSelectorTest.java | 12 +++--
.../kafka/common/security/ssl/SslFactoryTest.java | 37 ++++++++++---
.../ssl/mock/TestPlainSaslServerProvider.java} | 14 ++---
.../mock/TestPlainSaslServerProviderCreator.java | 20 +++----
.../security/ssl/mock/TestProviderCreator.java} | 24 ++++-----
.../ssl/mock/TestScramSaslServerProvider.java} | 14 ++---
.../mock/TestScramSaslServerProviderCreator.java | 20 +++----
.../kafka/common/utils/SecurityUtilsTest.java | 63 ++++++++++++++++++++++
core/src/main/scala/kafka/server/KafkaConfig.scala | 4 ++
.../scala/unit/kafka/server/KafkaConfigTest.scala | 3 ++
19 files changed, 267 insertions(+), 87 deletions(-)
copy clients/src/main/java/org/apache/kafka/common/config/{Config.java =>
SecurityConfig.java} (71%)
copy
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ToleranceType.java
=>
clients/src/main/java/org/apache/kafka/common/security/SecurityProviderCreator.java
(60%)
copy
clients/src/{main/java/org/apache/kafka/common/errors/ControllerMovedException.java
=>
test/java/org/apache/kafka/common/security/ssl/mock/TestPlainSaslServerProvider.java}
(67%)
copy
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterDetailsImpl.java
=>
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestPlainSaslServerProviderCreator.java
(65%)
copy
clients/src/{main/java/org/apache/kafka/common/record/AbstractRecordBatch.java
=>
test/java/org/apache/kafka/common/security/ssl/mock/TestProviderCreator.java}
(67%)
copy
clients/src/{main/java/org/apache/kafka/common/errors/ControllerMovedException.java
=>
test/java/org/apache/kafka/common/security/ssl/mock/TestScramSaslServerProvider.java}
(67%)
copy
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/health/ConnectClusterDetailsImpl.java
=>
clients/src/test/java/org/apache/kafka/common/security/ssl/mock/TestScramSaslServerProviderCreator.java
(65%)
