diff --git a/0001-adopt-huaweimaven.patch b/0001-adopt-huaweimaven.patch
new file mode 100644
index 0000000000000000000000000000000000000000..e38b9f4c2b14bfbfdc5b8e0b8ad1ccfedc9c575b
--- /dev/null
+++ b/0001-adopt-huaweimaven.patch
@@ -0,0 +1,48 @@
+diff -Naur kafka-2.8.1-src/build.gradle kafka-2.8.1-src-change/build.gradle
+--- kafka-2.8.1-src/build.gradle	2021-09-14 21:03:12.000000000 +0800
++++ kafka-2.8.1-src-change/build.gradle	2022-08-11 22:41:08.381225132 +0800
+@@ -19,11 +19,7 @@
+ 
+ buildscript {
+   repositories {
+-    mavenCentral()
+-    jcenter()
+-    maven {
+-      url "https://plugins.gradle.org/m2/"
+-    }
++    maven{url 'https://repo.huaweicloud.com/repository/maven/'}
+   }
+   apply from: file('gradle/buildscript.gradle'), to: buildscript
+   apply from: "$rootDir/gradle/dependencies.gradle"
+@@ -54,7 +50,7 @@
+ allprojects {
+ 
+   repositories {
+-    mavenCentral()
++    maven{url 'https://repo.huaweicloud.com/repository/maven/'}
+   }
+ 
+   apply plugin: 'idea'
+diff -Naur kafka-2.8.1-src/gradle/buildscript.gradle kafka-2.8.1-src-change/gradle/buildscript.gradle
+--- kafka-2.8.1-src/gradle/buildscript.gradle	2021-09-14 21:03:12.000000000 +0800
++++ kafka-2.8.1-src-change/gradle/buildscript.gradle	2022-08-11 23:00:43.143217999 +0800
+@@ -17,7 +17,7 @@
+   repositories {
+     // For license plugin.
+     maven {
+-      url 'https://dl.bintray.com/content/netflixoss/external-gradle-plugins/'
++      url 'https://repo.huaweicloud.com/repository/maven/'
+     }
+   }
+ }
+diff -Naur kafka-2.8.1-src/gradle/wrapper/gradle-wrapper.properties kafka-2.8.1-src-change/gradle/wrapper/gradle-wrapper.properties
+--- kafka-2.8.1-src/gradle/wrapper/gradle-wrapper.properties	2021-09-14 21:03:12.000000000 +0800
++++ kafka-2.8.1-src-change/gradle/wrapper/gradle-wrapper.properties	2022-08-11 22:41:33.044813236 +0800
+@@ -1,5 +1,6 @@
+ distributionBase=GRADLE_USER_HOME
+ distributionPath=wrapper/dists
+-distributionUrl=https\://services.gradle.org/distributions/gradle-6.8.1-all.zip
++#distributionUrl=https\://services.gradle.org/distributions/gradle-6.8.1-all.zip
++distributionUrl=https\://mirrors.huaweicloud.com/gradle/gradle-6.8.1-all.zip
+ zipStoreBase=GRADLE_USER_HOME
+ zipStorePath=wrapper/dists
diff --git a/gradle-6.5-bin.zip b/gradle-6.8.1-all.zip
similarity index 66%
rename from gradle-6.5-bin.zip
rename to gradle-6.8.1-all.zip
index aa94644bd073794b801b615530cab0b3593a74d1..4b31ee74ae948ecc4633d46109a69b5f164b93d8 100644
Binary files a/gradle-6.5-bin.zip and b/gradle-6.8.1-all.zip differ
diff --git a/gradle-wrapper.jar b/gradle-wrapper.jar
new file mode 100644
index 0000000000000000000000000000000000000000..e708b1c023ec8b20f512888fe07c5bd3ff77bb8f
Binary files /dev/null and b/gradle-wrapper.jar differ
diff --git a/kafka-2.6.0-src.tgz b/kafka-2.8.1-src.tgz
similarity index 49%
rename from kafka-2.6.0-src.tgz
rename to kafka-2.8.1-src.tgz
index 19dbec6365c2a7562803bfea6698f887bf26e0d4..fe7506fe4b615f617236514096f77a451e234ba6 100644
Binary files a/kafka-2.6.0-src.tgz and b/kafka-2.8.1-src.tgz differ
diff --git a/kafka.spec b/kafka.spec
index c2bd2ae0ef1216577ffcac0eb571eed006d96d23..7b2344371cb897747be3b639d1312c29017117dc 100644
--- a/kafka.spec
+++ b/kafka.spec
@@ -3,14 +3,16 @@
 %define kafka_home /opt/kafka
 
 Name: kafka
-Version: 2.6.0
-Release: 2
+Version: 2.8.1
+Release: 1
 Summary: A Distributed Streaming Platform.
 
-License: Apache License, Version 2.0
+License: Apache-2.0
 Source0: https://archive.apache.org/dist/%{name}/%{version}/%{name}-%{version}-src.tgz
-Source1: https://services.gradle.org/distributions/gradle-6.5-bin.zip
+Source1: https://mirrors.huaweicloud.com/gradle/gradle-6.8.1-all.zip
 Source2: kafka.service
+Source3: gradle-wrapper.jar
+Patch0: 0001-adopt-huaweimaven.patch
 
 BuildRequires: systemd java-1.8.0-openjdk-devel
 Provides: kafka = %{version}
@@ -27,22 +29,28 @@ getent passwd %{name} >/dev/null || \
 exit 0
 
 %prep
-%setup -q -n %{name}-%{version}-src
+%autosetup -p1 -n %{name}-%{version}-src
+cp -r $RPM_SOURCE_DIR/gradle-6.8.1-all.zip  %{_builddir}/kafka-2.8.1-src/gradle/wrapper/
+cp -r $RPM_SOURCE_DIR/gradle-wrapper.jar   %{_builddir}/kafka-2.8.1-src/gradle/wrapper/
 
 %build
-unzip -q $RPM_SOURCE_DIR/gradle-6.5-bin.zip
-./gradle-6.5/bin/gradle
-./gradlew jar
+unzip -q $RPM_SOURCE_DIR/gradle-6.8.1-all.zip
+./gradle-6.8.1/bin/gradle --info
+./gradlew jar releaseTarGz 
+
 
 %install
-mkdir -p $RPM_BUILD_ROOT%{kafka_home}/{libs,bin,config}
+mkdir -p $RPM_BUILD_ROOT%{kafka_home}/{libs,bin,config,site-docs,licenses}
+cd  %{_builddir}/kafka-2.8.1-src/core/build/distributions/
+tar -xvf kafka_2.13-2.8.1.tgz 
+cp -pr  kafka_2.13-2.8.1 %{_builddir}
+cd %{_builddir}/kafka_2.13-2.8.1
 
-install -p -D -m 755 bin/*.sh $RPM_BUILD_ROOT%{kafka_home}/bin
-install -p -D -m 644 config/* $RPM_BUILD_ROOT%{kafka_home}/config
-cp -n */build/libs/* $RPM_BUILD_ROOT%{kafka_home}/libs
-cp -n */build/dependant-libs*/* $RPM_BUILD_ROOT%{kafka_home}/libs
-cp -n */*/build/libs/* $RPM_BUILD_ROOT%{kafka_home}/libs
-cp -n */*/build/dependant-libs*/* $RPM_BUILD_ROOT%{kafka_home}/libs
+cp -pr libs/* $RPM_BUILD_ROOT%{kafka_home}/libs
+cp -pr bin/* $RPM_BUILD_ROOT%{kafka_home}/bin
+cp -pr config/* $RPM_BUILD_ROOT%{kafka_home}/config
+cp -pr site-docs/* $RPM_BUILD_ROOT%{kafka_home}/site-docs
+cp -pr licenses/*   $RPM_BUILD_ROOT%{kafka_home}/licenses
 
 %files
 %defattr(-,root,root)
@@ -56,6 +64,9 @@ cp -n */*/build/dependant-libs*/* $RPM_BUILD_ROOT%{kafka_home}/libs
 rm -rf %{buildroot}
 
 %changelog
+* Thu Aug 11 2022 xiexing <xiexing4@hisilicon.com> - 2.8.1-1
+- update version to fix CVE-2021-38153
+
 * Thu Mar 25 2021 huanghaitao <huanghaitao8@huawei.com> 2.6.0 - 2
 - Remove dist macros