Merge pull request #30 from sweet-security/0.1.9

0.1.9
sweet-security · Oct 13, 2024 · 0c9ee0e · 0c9ee0e
2 parents 77aeb82 + 94418f9
commit 0c9ee0e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@sweet-security/kafkas",
-  "version": "0.1.8",
+  "version": "0.1.9",
   "description": "An kafkajs decorator with cooperative sticky assigner support",
   "main": "index.js",
   "types": "types/index.d.ts",

diff --git a/src/consumer/assigners/cooperativeStickyAssigner/utils.js b/src/consumer/assigners/cooperativeStickyAssigner/utils.js
@@ -77,8 +77,7 @@ const getMemberIdToAssignPartitionTo = (members, assignment, topicWithMostUnassi
   // Amongst the members with the least assigned partitions, find the one with the least amount of partitions assigned to it from the topic with most unassigned partitions
   return minBy(
     membersByAssignedPartitionsCount[leastAssignedPartitionsCount],
-    member => assignment[member.memberId][topicWithMostUnassignedPartitions].length
-  )
+    member => assignment[member.memberId][topicWithMostUnassignedPartitions]?.length ?? 0  )
 }
 
 const unloadOverloadedMembers = (assignment, avgPartitions) => {