Skip to content

Commit 09f295b

Browse files
committed
update migration manifests
1 parent a2b7009 commit 09f295b

File tree

4 files changed

+82
-4
lines changed

4 files changed

+82
-4
lines changed

examples/kraft-migration/02-start-controllers.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ spec:
1818
zookeeperConfigMapName: simple-kafka-znode
1919
brokers:
2020
envOverrides:
21-
KAFKA_CLUSTER_ID: "saiZFmAuSX-QyMfMhwLk9g"
21+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
2222
roleGroups:
2323
default:
2424
replicas: 3
@@ -27,7 +27,7 @@ spec:
2727
default:
2828
replicas: 3
2929
envOverrides:
30-
KAFKA_CLUSTER_ID: "saiZFmAuSX-QyMfMhwLk9g"
30+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
3131
configOverrides:
3232
controller.properties:
3333
zookeeper.metadata.migration.enable: "true" # Enable migration mode so the controller can read metadata from ZooKeeper.

examples/kraft-migration/03-migrate-metadata.yaml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ spec:
1818
zookeeperConfigMapName: simple-kafka-znode
1919
brokers:
2020
envOverrides:
21-
KAFKA_CLUSTER_ID: "saiZFmAuSX-QyMfMhwLk9g"
21+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
2222
roleGroups:
2323
default:
2424
replicas: 3
@@ -41,7 +41,7 @@ spec:
4141
default:
4242
replicas: 3
4343
envOverrides:
44-
KAFKA_CLUSTER_ID: "saiZFmAuSX-QyMfMhwLk9g"
44+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
4545
configOverrides:
4646
controller.properties:
4747
zookeeper.metadata.migration.enable: "true" # Enable migration mode so the controller can read metadata from ZooKeeper.
Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
---
2+
apiVersion: kafka.stackable.tech/v1alpha1
3+
kind: KafkaCluster
4+
metadata:
5+
name: simple-kafka
6+
namespace: kraft-migration
7+
spec:
8+
image:
9+
productVersion: 3.9.1
10+
pullPolicy: IfNotPresent
11+
clusterConfig:
12+
metadataManager: ZooKeeper
13+
authentication:
14+
- authenticationClass: kafka-client-auth-tls
15+
tls:
16+
internalSecretClass: kafka-internal-tls
17+
serverSecretClass: tls
18+
zookeeperConfigMapName: simple-kafka-znode
19+
brokers:
20+
envOverrides:
21+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
22+
roleGroups:
23+
default:
24+
replicas: 3
25+
configOverrides:
26+
broker.properties:
27+
controller.listener.names: "CONTROLLER"
28+
controller.quorum.voters: "2110489703@simple-kafka-controller-default-0.simple-kafka-controller-default-headless.kraft-migration.svc.cluster.local:9093,2110489704@simple-kafka-controller-default-1.simple-kafka-controller-default-headless.kraft-migration.svc.cluster.local:9093,2110489705@simple-kafka-controller-default-2.simple-kafka-controller-default-headless.kraft-migration.svc.cluster.local:9093"
29+
process.roles: "broker"
30+
node.id: "${env:REPLICA_ID}"
31+
32+
# Remove or comment out the following properties:
33+
# broker.id - This property is replaced by node.id in KRaft mode.
34+
# inter.broker.protocol.version
35+
# zookeeper.metadata.migration.enable=true
36+
# zookeeper.connect
37+
38+
controllers:
39+
roleGroups:
40+
default:
41+
replicas: 3
42+
envOverrides:
43+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
44+
configOverrides:
45+
controller.properties:
46+
zookeeper.metadata.migration.enable: "true" # Enable migration mode so the controller can read metadata from ZooKeeper.
Lines changed: 32 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
---
2+
apiVersion: kafka.stackable.tech/v1alpha1
3+
kind: KafkaCluster
4+
metadata:
5+
name: simple-kafka
6+
namespace: kraft-migration
7+
spec:
8+
image:
9+
productVersion: 3.9.1
10+
pullPolicy: IfNotPresent
11+
clusterConfig:
12+
metadataManager: KRaft
13+
authentication:
14+
- authenticationClass: kafka-client-auth-tls
15+
tls:
16+
internalSecretClass: kafka-internal-tls
17+
serverSecretClass: tls
18+
brokers:
19+
envOverrides:
20+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"
21+
roleGroups:
22+
default:
23+
replicas: 3
24+
configOverrides:
25+
broker.properties:
26+
controller.listener.names: "CONTROLLER"
27+
controllers:
28+
roleGroups:
29+
default:
30+
replicas: 3
31+
envOverrides:
32+
KAFKA_CLUSTER_ID: "cPh4Fb3pRvyqiiVjaBDaEw"

0 commit comments

Comments
 (0)