You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2019/05/07 22:53:09 UTC
[kafka] branch 2.0 updated (1f902a5 -> e97c0e9)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 1f902a5 KAFKA-8306; Initialize log end offset accurately when start offset is non-zero (#6652)
add e97c0e9 KAFKA-8304: Fix registration of Connect REST extensions (#6651)
No new revisions were added by this update.
Summary of changes:
checkstyle/import-control.xml | 2 +
.../kafka/connect/cli/ConnectDistributed.java | 6 +-
.../kafka/connect/cli/ConnectStandalone.java | 6 +-
.../org/apache/kafka/connect/runtime/Connect.java | 1 +
.../kafka/connect/runtime/HerderProvider.java | 68 ------------
.../runtime/health/ConnectClusterStateImpl.java | 12 +--
.../kafka/connect/runtime/rest/RestServer.java | 66 +++++++-----
.../rest/resources/ConnectorPluginsResource.java | 12 +--
.../runtime/rest/resources/ConnectorsResource.java | 39 +++----
.../runtime/rest/resources/RootResource.java | 8 +-
.../integration/RestExtensionIntegrationTest.java | 119 +++++++++++++++++++++
.../health/ConnectClusterStateImplTest.java | 5 +-
.../kafka/connect/runtime/rest/RestServerTest.java | 10 +-
.../resources/ConnectorPluginsResourceTest.java | 3 +-
.../rest/resources/ConnectorsResourceTest.java | 3 +-
.../runtime/rest/resources/RootResourceTest.java | 3 +-
.../util/clusters/EmbeddedConnectCluster.java | 2 +-
17 files changed, 207 insertions(+), 158 deletions(-)
delete mode 100644 connect/runtime/src/main/java/org/apache/kafka/connect/runtime/HerderProvider.java
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/integration/RestExtensionIntegrationTest.java