diff --git a/driver-kafka/deploy/hdd-deployment/alicloud/deploy.yaml b/driver-kafka/deploy/hdd-deployment/alicloud/deploy.yaml
index 24575d44..24816a5d 100644
--- a/driver-kafka/deploy/hdd-deployment/alicloud/deploy.yaml
+++ b/driver-kafka/deploy/hdd-deployment/alicloud/deploy.yaml
@@ -54,7 +54,7 @@
- set_fact:
zookeeperServers: "{{ groups['zookeeper'] | map('extract', hostvars, ['ansible_default_ipv4', 'address']) | map('regex_replace', '^(.*)$', '\\1:2181') | join(',') }}"
boostrapServers: "{{ groups['kafka'] | map('extract', hostvars, ['private_ip']) | map('regex_replace', '^(.*)$', '\\1:9092') | join(',') }}"
- kafkaVersion: "2.0.0"
+ kafkaVersion: "3.6.1"
- debug:
msg: "zookeeper servers: {{ zookeeperServers }}\nboostrap servers: {{ boostrapServers }}"
- name: Download Kafka package
diff --git a/driver-kafka/deploy/hdd-deployment/deploy.yaml b/driver-kafka/deploy/hdd-deployment/deploy.yaml
index a8d1de38..b9f632b7 100644
--- a/driver-kafka/deploy/hdd-deployment/deploy.yaml
+++ b/driver-kafka/deploy/hdd-deployment/deploy.yaml
@@ -80,7 +80,7 @@
- set_fact:
zookeeperServers: "{{ groups['zookeeper'] | map('extract', hostvars, ['ansible_default_ipv4', 'address']) | map('regex_replace', '^(.*)$', '\\1:2181') | join(',') }}"
boostrapServers: "{{ groups['kafka'] | map('extract', hostvars, ['private_ip']) | map('regex_replace', '^(.*)$', '\\1:9092') | join(',') }}"
- kafkaVersion: "2.8.1"
+ kafkaVersion: "3.6.1"
- debug:
msg: "zookeeper servers: {{ zookeeperServers }}\nboostrap servers: {{ boostrapServers }}"
- name: Download Kafka package
diff --git a/driver-kafka/deploy/ssd-deployment/alicloud/deploy.yaml b/driver-kafka/deploy/ssd-deployment/alicloud/deploy.yaml
index 24575d44..24816a5d 100644
--- a/driver-kafka/deploy/ssd-deployment/alicloud/deploy.yaml
+++ b/driver-kafka/deploy/ssd-deployment/alicloud/deploy.yaml
@@ -54,7 +54,7 @@
- set_fact:
zookeeperServers: "{{ groups['zookeeper'] | map('extract', hostvars, ['ansible_default_ipv4', 'address']) | map('regex_replace', '^(.*)$', '\\1:2181') | join(',') }}"
boostrapServers: "{{ groups['kafka'] | map('extract', hostvars, ['private_ip']) | map('regex_replace', '^(.*)$', '\\1:9092') | join(',') }}"
- kafkaVersion: "2.0.0"
+ kafkaVersion: "3.6.1"
- debug:
msg: "zookeeper servers: {{ zookeeperServers }}\nboostrap servers: {{ boostrapServers }}"
- name: Download Kafka package
diff --git a/driver-kafka/deploy/ssd-deployment/deploy.yaml b/driver-kafka/deploy/ssd-deployment/deploy.yaml
index 6a1e502b..d02ce5dd 100644
--- a/driver-kafka/deploy/ssd-deployment/deploy.yaml
+++ b/driver-kafka/deploy/ssd-deployment/deploy.yaml
@@ -103,7 +103,7 @@
- set_fact:
zookeeperServers: "{{ groups['zookeeper'] | map('extract', hostvars, ['ansible_default_ipv4', 'address']) | map('regex_replace', '^(.*)$', '\\1:2181') | join(',') }}"
bootstrapServers: "{{ groups['kafka'] | map('extract', hostvars, ['private_ip']) | map('regex_replace', '^(.*)$', '\\1:9092') | join(',') }}"
- kafkaVersion: "3.2.1"
+ kafkaVersion: "3.6.1"
tags: [client-code]
- debug:
msg: "zookeeper servers: {{ zookeeperServers }}\nbootstrap servers: {{ bootstrapServers }}"
diff --git a/driver-kafka/pom.xml b/driver-kafka/pom.xml
index 176bdfff..83324ab5 100644
--- a/driver-kafka/pom.xml
+++ b/driver-kafka/pom.xml
@@ -33,7 +33,7 @@
org.apache.kafka
kafka-clients
- 3.2.1
+ 3.6.1
org.projectlombok