dawidwys commented on a change in pull request #13360:
URL: https://github.com/apache/flink/pull/13360#discussion_r487769851
##########
File path: docs/dev/connectors/kafka.md
##########
@@ -554,14 +551,26 @@ A mismatch in service name between client and server
configuration will cause th
For more information on Flink configuration for Kerberos security, please see
[here]({{ site.baseurl}}/ops/config.html).
You can also find [here]({{ site.baseurl}}/ops/security-kerberos.html) further
details on how Flink internally setups Kerberos-based security.
-## Migrating Kafka Connector from 0.11 to universal
+## Upgrading from the Kafka 0.11.x connector to the latest connector
+
+The generic upgrade steps are outlined in [upgrading jobs and Flink versions
+guide]({{ site.baseurl }}/ops/upgrading.html). For Kafka, you additionally need
+to follow these steps:
+
+* Do not upgrade Flink and the Kafka Connector version at the same time.
+* Make sure you have a `group.id` configured for your Consumer.
+* Set `setCommitOffsetsOnCheckpoints(true)` on the consumer so that read
+ offsets are committed to Kafka. It's important to do this before stopping and
+ taking the savepoint. You might have to to a stop/restart cycle on the old
Review comment:
```suggestion
taking the savepoint. You might have to do a stop/restart cycle on the old
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
