Merge commit '265b8815' into june-30-merge
Make ConfluentV1MetadataResource implement ConnectResource
显示
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java 1 个添加, 1 个删除...kafka/clients/consumer/internals/AbstractCoordinator.java
- clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetcherMetricsRegistry.java 1 个添加, 1 个删除...ka/clients/consumer/internals/FetcherMetricsRegistry.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java 2 个添加, 7 个删除...c/main/java/org/apache/kafka/connect/runtime/Connect.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java 2 个添加, 2 个删除...rc/main/java/org/apache/kafka/connect/runtime/Worker.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java 21 个添加, 7 个删除...ava/org/apache/kafka/connect/runtime/rest/RestServer.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConfluentV1MetadataResource.java 6 个添加, 1 个删除...t/runtime/rest/resources/ConfluentV1MetadataResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectResource.java 40 个添加, 0 个删除...kafka/connect/runtime/rest/resources/ConnectResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java 9 个添加, 2 个删除...nect/runtime/rest/resources/ConnectorPluginsResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java 9 个添加, 17 个删除...ka/connect/runtime/rest/resources/ConnectorsResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java 6 个添加, 1 个删除...kafka/connect/runtime/rest/resources/LoggingResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/RootResource.java 6 个添加, 1 个删除...he/kafka/connect/runtime/rest/resources/RootResource.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java 31 个添加, 16 个删除...ache/kafka/connect/integration/BlockingConnectorTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java 10 个添加, 0 个删除...e/kafka/connect/util/clusters/EmbeddedConnectCluster.java
- connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/WorkerHandle.java 13 个添加, 3 个删除.../org/apache/kafka/connect/util/clusters/WorkerHandle.java
- core/src/main/scala/kafka/cluster/Partition.scala 1 个添加, 1 个删除core/src/main/scala/kafka/cluster/Partition.scala
- core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala 15 个添加, 24 个删除...ala/integration/kafka/api/AuthorizerIntegrationTest.scala
- core/src/test/scala/integration/kafka/api/GroupAuthorizerIntegrationTest.scala 42 个添加, 18 个删除...ntegration/kafka/api/GroupAuthorizerIntegrationTest.scala
- core/src/test/scala/integration/kafka/server/QuorumTestHarness.scala 11 个添加, 8 个删除...st/scala/integration/kafka/server/QuorumTestHarness.scala
- core/src/test/scala/unit/kafka/cluster/PartitionTest.scala 111 个添加, 2 个删除core/src/test/scala/unit/kafka/cluster/PartitionTest.scala
- core/src/test/scala/unit/kafka/integration/KafkaServerTestHarness.scala 10 个添加, 0 个删除...scala/unit/kafka/integration/KafkaServerTestHarness.scala
加载中
想要评论请 注册 或 登录