diff --git a/docs/ops.html b/docs/ops.html index ecfd294291dc4..e283cbc456f57 100644 --- a/docs/ops.html +++ b/docs/ops.html @@ -596,9 +596,9 @@
For existing MirrorMaker clusters, a two-step upgrade is necessary. Instead of immediately setting the exactly.once.source.support
property to enabled, first set it to preparing
on all nodes in the cluster. Once this is complete, it can be set to enabled
on all nodes in the cluster, in a second round of restarts.
In either case, it is also necessary to enable intra-cluster communication between the MirrorMaker nodes, as described in KIP-710. To do this, the dedicated.mode.enable.internal.rest
property must be set to true
. In addition, many of the REST-related configuration properties available for Kafka Connect can be specified the MirrorMaker config. For example, to enable intra-cluster communication in MirrorMaker cluster with each node listening on port 8080 of their local machine, the following should be added to the MirrorMaker config file:
dedicated.mode.enable.internal.rest = true
listeners = http://localhost:8080
-
+
Note that, if intra-cluster communication is enabled in production environments, it is highly recommended to secure the REST servers brought up by each MirrorMaker node. See the configuration properties for Kafka Connect for information on how this can be accomplished.
- +
It is also recommended to filter records from aborted transactions out from replicated data when running MirrorMaker. To do this, ensure that the consumer used to read from source clusters is configured with isolation.level
set to read_committed
. If replicating data from cluster us-west
, this can be done for all replication flows that read from that cluster by adding the following to the MirrorMaker config file:
With the release of Apache Kafka 3.5, Zookeeper is now marked deprecated. Removal of ZooKeeper is planned in the next major release of Apache Kafka (version 4.0), which is scheduled to happen no sooner than April 2024. During the deprecation phase, ZooKeeper is still supported for metadata management of Kafka clusters, @@ -3732,10 +3732,10 @@
Users are recommended to begin planning for migration to KRaft and also begin testing to provide any feedback. Refer to ZooKeeper to KRaft Migration for details on how to perform a live migration from ZooKeeper to KRaft and current limitations.
- +The final 3.x minor release, that supports ZooKeeper mode, will receive critical bug fixes and security fixes for 12 months after its release.
- +$ bin/kafka-storage format --cluster-id --standalone --config controller.properties
+ $ bin/kafka-storage format --cluster-id <cluster-id> --standalone --config controller.properties
This command will 1) create a meta.properties file in metadata.log.dir with a randomly generated directory.id, 2) create a snapshot at 00000000000000000000-0000000000.checkpoint with the necessary control records (KRaftVersionRecord and VotersRecord) to make this Kafka node the only voter for the quorum.
@@ -3820,7 +3820,7 @@ kafka-storage.sh format
command without the --standalone or --initial-controllers flags.
- $ bin/kafka-storage format --cluster-id --config server.properties
+ $ bin/kafka-storage format --cluster-id <cluster-id> --config server.properties
$ bin/kafka-metadata-quorum --bootstrap-server localhost:9092 remove-controller --controller-id --controller-directory-id
+ $ bin/kafka-metadata-quorum --bootstrap-server localhost:9092 remove-controller --controller-id <id> --controller-directory-id <directory-id>
When using controller endpoints use the --bootstrap-controller flag:
- $ bin/kafka-metadata-quorum --bootstrap-controller localhost:9092 remove-controller --controller-id --controller-directory-id
+ $ bin/kafka-metadata-quorum --bootstrap-controller localhost:9092 remove-controller --controller-id <id> --controller-directory-id <directory-id>
zookeeper.metadata.migration.enable
remains set to
- true. Do not set it to false until the second cluster roll.
+ true
. Do not set it to false until the second cluster roll.