KGLOBAL-1727 : add NetworkRegionId tag to CL SaslAuthenticate request (#6912)
* KGLOBAL-1727 : add NetworkRegionId tag to CL SaslAuthenticate request if available * fixed broken test * added more tests * minor cleanups * minor cleanups * added debug logs * added tests for request callback * fixing broken test * bumped version in tests for SASL_AUTHENTICATE * moved back version to 2 and fixed review comments * added verify that no tags are added and also fixed broken test * fixed minor indents and import order issues * moved traffic config to Confluent config
显示
- clients/src/main/java/org/apache/kafka/common/config/internals/ConfluentConfigs.java 5 个添加, 0 个删除...pache/kafka/common/config/internals/ConfluentConfigs.java
- clients/src/main/java/org/apache/kafka/common/network/ChannelBuilders.java 29 个添加, 1 个删除...java/org/apache/kafka/common/network/ChannelBuilders.java
- clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java 2 个添加, 1 个删除...a/org/apache/kafka/common/network/SaslChannelBuilder.java
- clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java 8 个添加, 1 个删除...ommon/security/authenticator/SaslClientAuthenticator.java
- clients/src/main/resources/common/message/SaslAuthenticateRequest.json 3 个添加, 1 个删除...ain/resources/common/message/SaslAuthenticateRequest.json
- clients/src/test/java/org/apache/kafka/common/requests/RequestResponseTest.java 15 个添加, 0 个删除...org/apache/kafka/common/requests/RequestResponseTest.java
- clients/src/test/java/org/apache/kafka/common/security/authenticator/SaslAuthenticatorTest.java 24 个添加, 7 个删除.../common/security/authenticator/SaslAuthenticatorTest.java
- core/src/main/scala/kafka/server/DynamicBrokerConfig.scala 1 个添加, 0 个删除core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
- core/src/main/scala/kafka/server/KafkaConfig.scala 4 个添加, 2 个删除core/src/main/scala/kafka/server/KafkaConfig.scala
- core/src/main/scala/kafka/server/link/ClusterLinkAdminClient.scala 4 个添加, 2 个删除...main/scala/kafka/server/link/ClusterLinkAdminClient.scala
- core/src/main/scala/kafka/server/link/ClusterLinkAdminManager.scala 1 个添加, 1 个删除...ain/scala/kafka/server/link/ClusterLinkAdminManager.scala
- core/src/main/scala/kafka/server/link/ClusterLinkFetcherManager.scala 1 个添加, 1 个删除...n/scala/kafka/server/link/ClusterLinkFetcherManager.scala
- core/src/main/scala/kafka/server/link/ClusterLinkFetcherThread.scala 1 个添加, 0 个删除...in/scala/kafka/server/link/ClusterLinkFetcherThread.scala
- core/src/main/scala/kafka/server/link/ClusterLinkManager.scala 1 个添加, 0 个删除...src/main/scala/kafka/server/link/ClusterLinkManager.scala
- core/src/main/scala/kafka/server/link/ClusterLinkMetadataThread.scala 4 个添加, 1 个删除...n/scala/kafka/server/link/ClusterLinkMetadataThread.scala
- core/src/main/scala/kafka/server/link/ClusterLinkNetworkClient.scala 23 个添加, 5 个删除...in/scala/kafka/server/link/ClusterLinkNetworkClient.scala
- core/src/main/scala/kafka/server/link/ClusterLinkSourceConnectionManager.scala 1 个添加, 1 个删除...afka/server/link/ClusterLinkSourceConnectionManager.scala
- core/src/main/scala/kafka/server/link/ClusterLinkUtils.scala 9 个添加, 0 个删除core/src/main/scala/kafka/server/link/ClusterLinkUtils.scala
- core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala 1 个添加, 0 个删除core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
- core/src/test/scala/unit/kafka/server/link/ClusterLinkMetadataThreadTest.scala 2 个添加, 1 个删除...nit/kafka/server/link/ClusterLinkMetadataThreadTest.scala
加载中
想要评论请 注册 或 登录