Merge remote-tracking branch 'kafka-github/trunk' into merge-ak
显示
- checkstyle/suppressions.xml 1 个添加, 1 个删除checkstyle/suppressions.xml
- clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java 1 个添加, 1 个删除...java/org/apache/kafka/clients/admin/KafkaAdminClient.java
- clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java 13 个添加, 0 个删除.../kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
- clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java 12 个添加, 3 个删除...ents/admin/internals/ListConsumerGroupOffsetsHandler.java
- clients/src/test/java/org/apache/kafka/clients/admin/AdminClientTestUtils.java 7 个添加, 0 个删除.../org/apache/kafka/clients/admin/AdminClientTestUtils.java
- clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java 33 个添加, 0 个删除.../org/apache/kafka/clients/admin/KafkaAdminClientTest.java
- clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java 33 个添加, 5 个删除.../java/org/apache/kafka/clients/admin/MockAdminClient.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java 7 个添加, 1 个删除...pache/kafka/connect/runtime/AbstractWorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java 0 个添加, 2 个删除...va/org/apache/kafka/connect/runtime/WorkerSourceTask.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java 123 个添加, 29 个删除.../kafka/connect/runtime/distributed/DistributedConfig.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java 1 个添加, 0 个删除...ka/connect/runtime/rest/resources/ConnectorsResource.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/ConnectorHandle.java 8 个添加, 0 个删除...org/apache/kafka/connect/integration/ConnectorHandle.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/ExactlyOnceSourceIntegrationTest.java 1130 个添加, 0 个删除...connect/integration/ExactlyOnceSourceIntegrationTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/MonitorableSourceConnector.java 120 个添加, 19 个删除...kafka/connect/integration/MonitorableSourceConnector.java
- connect/runtime/src/test/java/org/apache/kafka/connect/runtime/distributed/DistributedConfigTest.java 106 个添加, 3 个删除...ka/connect/runtime/distributed/DistributedConfigTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectClusterAssertions.java 3 个添加, 0 个删除...nnect/util/clusters/EmbeddedConnectClusterAssertions.java
- connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java 149 个添加, 1 个删除...che/kafka/connect/util/clusters/EmbeddedKafkaCluster.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
加载中
想要评论请 注册 或 登录