alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-4028 kcdrestextension -> kcrestextension

Browse Source
This commit is contained in:
Gunnar Morling 2021-10-05 11:19:59 +02:00
parent 8bdc6047bf
commit c81b211ed6
7 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-connect-rest-extension/README.md
View File

@ -1,18 +1,18 @@
Copyright Debezium Authors. Copyright Debezium Authors.
Licensed under the [Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0). Licensed under the [Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0).
# Debezium Kafka Connect Distributed (KCD) REST Extension # Debezium Kafka Connect REST Extension
Debezium is an open source distributed platform for change data capture (CDC). Debezium is an open source distributed platform for change data capture (CDC).
This repository contains extensions to Kafka Connect's REST API. This repository contains Debezium-specific extensions to Kafka Connect's REST API.
## Setup ## Setup
1. Install or mount the Debezium Kafka Connect REST Extension jar into a separate 1. Install or mount the Debezium Kafka Connect REST Extension jar into a separate
Kafka Connect plugin directory. Kafka Connect plugin directory.
For example with `docker-compose`: For example with Docker Compose:
```yaml ```yaml
volumes: volumes:
@ -23,10 +23,10 @@ This repository contains extensions to Kafka Connect's REST API.
```yaml ```yaml
environment: environment:
- CONNECT_REST_EXTENSION_CLASSES=io.debezium.kcdrestextension.DebeziumConnectRestExtension - CONNECT_REST_EXTENSION_CLASSES=io.debezium.kcrestextension.DebeziumConnectRestExtension
``` ```
or set `rest.extension.classes=io.debezium.kcdrestextension.DebeziumConnectRestExtension` in your Kafka Connect properties file. or set `rest.extension.classes=io.debezium.kcrestextension.DebeziumConnectRestExtension` in your Kafka Connect properties file.
## Contribution ## Contribution

2
debezium-connect-rest-extension/pom.xml
View File

@ -4,7 +4,7 @@
<parent> <parent>
<groupId>io.debezium</groupId> <groupId>io.debezium</groupId>
<artifactId>debezium-parent</artifactId> <artifactId>debezium-parent</artifactId>
<version>1.7.0-SNAPSHOT</version> <version>1.8.0-SNAPSHOT</version>
<relativePath>../debezium-parent/pom.xml</relativePath> <relativePath>../debezium-parent/pom.xml</relativePath>
</parent> </parent>
<modelVersion>4.0.0</modelVersion> <modelVersion>4.0.0</modelVersion>

4
debezium-connect-rest-extension/src/main/java/io/debezium/kcdrestextension/DebeziumConnectRestExtension.java → debezium-connect-rest-extension/src/main/java/io/debezium/kcrestextension/DebeziumConnectRestExtension.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.kcdrestextension; package io.debezium.kcrestextension;
import java.util.Map; import java.util.Map;
@ -20,7 +20,7 @@
* To install this extension put the jar file into a separate Kafka Connect * To install this extension put the jar file into a separate Kafka Connect
* plugin dir and configure your Kafka Connect properties file with: * plugin dir and configure your Kafka Connect properties file with:
* *
* `rest.extension.classes=io.debezium.kcdrestextension.DebeziumConnectRestExtension` * `rest.extension.classes=io.debezium.kcrestextension.DebeziumConnectRestExtension`
* *
*/ */
public class DebeziumConnectRestExtension implements ConnectRestExtension { public class DebeziumConnectRestExtension implements ConnectRestExtension {

4
debezium-connect-rest-extension/src/main/java/io/debezium/kcdrestextension/DebeziumResource.java → debezium-connect-rest-extension/src/main/java/io/debezium/kcrestextension/DebeziumResource.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.kcdrestextension; package io.debezium.kcrestextension;
import java.lang.Runtime.Version; import java.lang.Runtime.Version;
import java.lang.reflect.Field; import java.lang.reflect.Field;
@ -32,7 +32,7 @@
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import io.debezium.kcdrestextension.entities.TransformsInfo; import io.debezium.kcrestextension.entities.TransformsInfo;
/** /**
* A JAX-RS Resource class defining endpoints that enable some advanced features * A JAX-RS Resource class defining endpoints that enable some advanced features

2
debezium-connect-rest-extension/src/main/java/io/debezium/kcdrestextension/entities/PropertyDescriptor.java → debezium-connect-rest-extension/src/main/java/io/debezium/kcrestextension/entities/PropertyDescriptor.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.kcdrestextension.entities; package io.debezium.kcrestextension.entities;
import java.util.Arrays; import java.util.Arrays;
import java.util.HashMap; import java.util.HashMap;

2
debezium-connect-rest-extension/src/main/java/io/debezium/kcdrestextension/entities/TransformsInfo.java → debezium-connect-rest-extension/src/main/java/io/debezium/kcrestextension/entities/TransformsInfo.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.kcdrestextension.entities; package io.debezium.kcrestextension.entities;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;

2
debezium-connect-rest-extension/src/main/resources/META-INF/services/org.apache.kafka.connect.rest.ConnectRestExtension
View File

@ -1 +1 @@
io.debezium.kcdrestextension.DebeziumConnectRestExtension io.debezium.kcrestextension.DebeziumConnectRestExtension