Skip to content

Commit 541c4d9

Browse files
dhrudevaliaali-incenvitucci
authored
docs: add 5.1 migration guide (#53)
* docs: add confluent platform migration guide * docs: add sensitive properties section to migration * docs: add confluent cloud migration guide * docs: add migration to content nav * docs: move migration to reference section * docs: refactor migration into separate section and split into deployments * docs: use defined variables for version and product name * docs: update migration navigation bar * docs: update wording Co-authored-by: Nicola Vitucci <nicola.vitucci@gmail.com> * docs: move files into 5.1 specification section * docs: fix example indentation * Apply suggestions from code review Co-authored-by: Nicola Vitucci <nicola.vitucci@gmail.com> * docs: update navigation title --------- Co-authored-by: Ali Ince <ali-ince@users.noreply.github.com> Co-authored-by: Nicola Vitucci <nicola.vitucci@gmail.com>
1 parent f3dc048 commit 541c4d9

File tree

8 files changed

+118
-0
lines changed

8 files changed

+118
-0
lines changed

modules/ROOT/content-nav.adoc

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,11 @@
2525
* xref:sink/error-handling.adoc[Error handling]
2626
* xref:sink/configuration.adoc[Settings]
2727
28+
* *Upgrades and migrations*
29+
* xref:migration/5.1/index.adoc[Migrate to 5.1]
30+
** xref:migration/5.1/migration-docker.adoc[Confluent Platform]
31+
** xref:migration/5.1/migration-confluent-cloud.adoc[Confluent Cloud]
32+
2833
* *Reference*
2934
* xref::known-issues.adoc[]
3035
* xref::changelog.adoc[]
Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,18 @@
1+
connect | [2024-09-04 09:18:40,066] INFO The migrated settings for 5.1 version of Neo4j Source Connector 'Neo4jSourceConnectorAVRO' is: `{
2+
connect | "connector.class" : "org.neo4j.connectors.kafka.source.Neo4jConnector",
3+
connect | "neo4j.authentication.basic.password" : "",
4+
connect | "neo4j.uri" : "bolt://neo4j:7687",
5+
connect | "neo4j.query" : "MATCH (ts:TestSource) WHERE ts.timestamp > $lastCheck RETURN ts.name AS name, ts.surname AS surname, ts.timestamp AS timestamp",
6+
connect | "neo4j.query.streaming-property" : "timestamp",
7+
connect | "value.converter.schema.registry.url" : "http://schema-registry:8081",
8+
connect | "task.class" : "streams.kafka.connect.source.Neo4jSourceTask",
9+
connect | "neo4j.authentication.basic.username" : "neo4j",
10+
connect | "name" : "Neo4jSourceConnectorAVRO",
11+
connect | "neo4j.query.topic" : "my-topic",
12+
connect | "value.converter" : "io.confluent.connect.avro.AvroConverter",
13+
connect | "key.converter" : "io.confluent.connect.avro.AvroConverter",
14+
connect | "key.converter.schema.registry.url" : "http://schema-registry:8081",
15+
connect | "neo4j.query.poll-interval" : "5000ms",
16+
connect | "neo4j.start-from" : "USER_PROVIDED",
17+
connect | "neo4j.start-from.value" : 1725441505774
18+
connect | }` (streams.kafka.connect.source.Neo4jSourceService)
Loading
Loading
Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
[[connector-migration]]
2+
= Migrate from 5.0.x to 5.1
3+
4+
When upgrading the {product-name} to 5.1, be aware that many of the configuration properties have been changed and updated.
5+
Read over xref:whats-new.adoc[] to familiarize with the recent changes, and make sure that the new configuration logically matches the previous configuration.
6+
7+
For generic Kafka Connect plugin upgrade documentation see: https://docs.confluent.io/platform/current/connect/upgrade.html[Confluent Documentation -> Upgrade a Connector Plugin].
8+
9+
== Deployment guides
10+
11+
Follow the relevant instructions to configure and deploy the new connector.
12+
13+
* Read the xref:migration/5.1/migration-docker.adoc[Confluent Platform migration] for a connector deployed to Confluent Platform as a self-managed connector.
14+
* Read the xref:migration/5.1/migration-confluent-cloud.adoc[Confluent Cloud migration] for a connector deployed as a Custom Connector on Confluent Cloud.
15+
16+
== Troubleshooting
17+
18+
[qanda]
19+
Failing to connect to Neo4j instance?::
20+
The configuration migration process does not migrate the password of the Neo4j instance or other sensitive properties.
21+
You need to enter these properties again.
22+
Once updated, restart the connector.
23+
24+
Unexpected error::
25+
Looking at the logs of Kafka Connect may reveal other errors in configuration.
26+
. On Confluent Cloud, the logs are accessible through the *Logs* section on the Connector run page.
27+
. On Confluent Platform, the logs are accessible through the Docker command `docker-compose logs -f connect`.
Lines changed: 27 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,27 @@
1+
[[migration-confluent-cloud]]
2+
= Migration on Confluent Cloud
3+
4+
include::partial$third-party.adoc[]
5+
6+
IMPORTANT: Complete the following steps in full for each connector (source or sink) currently registered.
7+
8+
This guide follows the connector xref:quickstart-confluent-cloud.adoc[] execution method.
9+
10+
.Steps
11+
12+
. Access the Confluent Cloud cluster associated with the relevant connectors.
13+
. Open the *Connectors* section and find the relevant source or sink connector for upgrading.
14+
. Open the *Settings* section and select *Pause* to pause the connector.
15+
. Open the *Logs* section and search for a log message starting with `The migrated settings for 5.1 version of Neo4j`.
16+
+
17+
image::migration/confluent-cloud-config-log.png[width=800]
18+
19+
. Copy the configuration shown in the log into a local file.
20+
21+
include::partial$how-to-upgrade-validate-config.adoc[]
22+
23+
. Follow the xref:quickstart-confluent-cloud.adoc[] to upload the new 5.1 Connector plugin.
24+
. Create a Source or Sink instance.
25+
. Copy the migrated configuration from the local file into the Custom Configuration JSON section, and check that it is correct.
26+
. Continue with the steps in the Quickstart guide.
27+
. Once the connector is up and running, validate it is successfully running.
Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
[[migration-docker]]
2+
= Migration on Confluent Platform
3+
4+
This guide follows the xref:quickstart-docker.adoc[].
5+
6+
.Steps
7+
. Open the Confluent Control Center instance at `http://localhost:9021/clusters` and find the registered source or sink connector.
8+
Once found, delete it.
9+
10+
. Look at the logs for the `connect` container (`docker-compose logs -f connect`).
11+
A migrated configuration will be printed to the logs as part of the connector deletion/shutdown.
12+
Example:
13+
+
14+
[source,shell]
15+
----
16+
include::example$docker-data/how-to-upgrade.migrated-config.log[]
17+
----
18+
19+
. Create a new JSON file `(source/sink)_migrated.neo4j.json` and copy the migrated example config to this file along with the connector name.
20+
The configuration should contain a `name` property and the migrated configuration should be nested in the `config` key.
21+
22+
include::partial$how-to-upgrade-validate-config.adoc[]
23+
24+
. Download the new connector version following the xref:installation.adoc[] guide and remove the original 5.0.x connector version.
25+
Make sure to copy the new plugin into the `./plugins/` folder created during the Docker setup.
26+
27+
. Restart the Kafka Connect Worker by running `docker-compose restart connect`.
28+
This allows the Kafka Connect platform to pick up the new plugin from the `./plugins/` folder.
29+
30+
. Continue following the xref:quickstart-docker.adoc[] to deploy the plugin to Kafka Connect with the new configuration.
31+
32+
. Once the connector is up and running, validate it is successfully running.
33+
Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,8 @@
1+
. Validate that the new configuration contains all the relevant keys compared with the previous version of the connector configuration.
2+
.. See xref:source/configuration.adoc[] and xref:sink/configuration.adoc[] for descriptions and examples of the new configuration options.
3+
.. If migrating the Source component, make note of the `neo4j.start-from.value` that has been set to the last checked offset.
4+
.. Replace the sensitive values.
5+
[WARNING]
6+
Sensitive values in the original configuration are not printed in the migrated configuration.
7+
These keys need to be filled in with the appropriate values.
8+
The affected configuration keys are `neo4j.authentication.basic.password` and `neo4j.authentication.kerberos.ticket`.

0 commit comments

Comments
 (0)