diff --git a/0012-incorrectly-LeaderElectionCommand.patch b/0012-incorrectly-LeaderElectionCommand.patch new file mode 100644 index 0000000000000000000000000000000000000000..ede5b5f9c4244e2da4d69deaba363b3883864851 --- /dev/null +++ b/0012-incorrectly-LeaderElectionCommand.patch @@ -0,0 +1,13 @@ +diff --git a/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala b/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala +index 03737aa532..92edcad003 100644 +--- a/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala ++++ b/core/src/main/scala/kafka/admin/LeaderElectionCommand.scala +@@ -166,7 +166,7 @@ object LeaderElectionCommand extends Logging { + } + + if (noop.nonEmpty) { +- val partitions = succeeded.mkString(", ") ++ val partitions = noop.mkString(", ") + println(s"Valid replica already elected for partitions $partitions") + } + diff --git a/kafka.spec b/kafka.spec index 94fb164dd2a3b512ee5cc12b9ac3eb52114bb537..6573124807cda2ec7d02d488181181f42f8cd726 100644 --- a/kafka.spec +++ b/kafka.spec @@ -4,7 +4,7 @@ Name: kafka Version: 2.8.2 -Release: 11 +Release: 12 Summary: A Distributed Streaming Platform. License: Apache-2.0 @@ -23,6 +23,7 @@ Patch7: 0008-Cast-SMT-allow-null.patch Patch8: 0009-format-RocksDBConfigSetter.patch Patch9: 0010-not-update-connection.patch Patch10: 0011-ConfigEntry.patch +Patch11: 0012-incorrectly-LeaderElectionCommand.patch BuildRequires: systemd java-1.8.0-openjdk-devel Provides: kafka = %{version} @@ -74,8 +75,10 @@ cp -pr licenses/* $RPM_BUILD_ROOT%{kafka_home}/licenses rm -rf %{buildroot} %changelog +* Fri Dec 08 2023 sundapeng - 2.8.2-12 +- Fix noop set is incorrectly replaced with succeeded set from LeaderElectionCommand * Fri Dec 08 2023 sundapeng - 2.8.2-11 -- ConfigEntry#equal does not compare other fields when value is NOT null +- FetchSessionCache may cause starvation for partitions when FetchResponse is full * Fri Dec 08 2023 sundapeng - 2.8.2-10 - Don't update connection idle time for muted connections * Fri Dec 08 2023 sundapeng - 2.8.2-9