Merge commit '3ae1afa4~1'
显示
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java 123 个添加, 30 个删除.../kafka/connect/runtime/distributed/DistributedConfig.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.java 106 个添加, 3 个删除...ka/connect/runtime/distributed/DistributedConfigTest.java
- core/src/main/scala/kafka/cluster/BrokerEndPoint.scala 0 个添加, 37 个删除core/src/main/scala/kafka/cluster/BrokerEndPoint.scala
- core/src/main/scala/kafka/server/AlterPartitionManager.scala 2 个添加, 3 个删除core/src/main/scala/kafka/server/AlterPartitionManager.scala
- core/src/main/scala/kafka/server/BrokerServer.scala 27 个添加, 22 个删除core/src/main/scala/kafka/server/BrokerServer.scala
- core/src/main/scala/kafka/server/BrokerToControllerChannelManager.scala 1 个添加, 5 个删除...scala/kafka/server/BrokerToControllerChannelManager.scala
- core/src/main/scala/kafka/server/KafkaConfig.scala 5 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaConfig.scala
- core/src/main/scala/kafka/server/KafkaServer.scala 11 个添加, 8 个删除core/src/main/scala/kafka/server/KafkaServer.scala
- core/src/test/java/kafka/test/ClusterTestExtensionsTest.java 4 个添加, 0 个删除core/src/test/java/kafka/test/ClusterTestExtensionsTest.java
- core/src/test/java/kafka/test/annotation/Type.java 16 个添加, 2 个删除core/src/test/java/kafka/test/annotation/Type.java
- core/src/test/java/kafka/test/junit/RaftClusterInvocationContext.java 10 个添加, 7 个删除...t/java/kafka/test/junit/RaftClusterInvocationContext.java
- core/src/test/java/kafka/testkit/KafkaClusterTestKit.java 34 个添加, 9 个删除core/src/test/java/kafka/testkit/KafkaClusterTestKit.java
- core/src/test/java/kafka/testkit/TestKitNodes.java 23 个添加, 2 个删除core/src/test/java/kafka/testkit/TestKitNodes.java
- core/src/test/scala/unit/kafka/admin/LeaderElectionCommandTest.scala 1 个添加, 1 个删除...st/scala/unit/kafka/admin/LeaderElectionCommandTest.scala
- core/src/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala 0 个添加, 28 个删除...rc/test/scala/unit/kafka/cluster/BrokerEndPointTest.scala
- core/src/test/scala/unit/kafka/server/ApiVersionsRequestTest.scala 1 个添加, 1 个删除...test/scala/unit/kafka/server/ApiVersionsRequestTest.scala
- core/src/test/scala/unit/kafka/server/BrokerMetricNamesTest.scala 1 个添加, 1 个删除.../test/scala/unit/kafka/server/BrokerMetricNamesTest.scala
- core/src/test/scala/unit/kafka/server/ClientQuotasRequestTest.scala 1 个添加, 1 个删除...est/scala/unit/kafka/server/ClientQuotasRequestTest.scala
- core/src/test/scala/unit/kafka/server/ClusterLinksRequestTest.scala 27 个添加, 22 个删除...est/scala/unit/kafka/server/ClusterLinksRequestTest.scala
- core/src/test/scala/unit/kafka/server/ControllerApisTest.scala 1 个添加, 1 个删除...src/test/scala/unit/kafka/server/ControllerApisTest.scala
加载中
想要评论请 注册 或 登录