Skip to content

Commit 628dd81

Browse files
authored
fix: Fix mixed metadata callbacks in kPerformDeduplicated (#144)
1 parent e088f13 commit 628dd81

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/clients/base/base.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -356,7 +356,8 @@ export class Base<OptionsType extends BaseOptions = BaseOptions> extends EventEm
356356
const autocreateTopics = options.autocreateTopics ?? this[kOptions].autocreateTopics
357357

358358
this[kPerformDeduplicated](
359-
'metadata',
359+
// Unique key to avoid mixing callbacks
360+
`metadata-${options.topics.sort().join(',')}-${autocreateTopics}-${options.forceUpdate}`,
360361
deduplicateCallback => {
361362
this[kPerformWithRetry]<MetadataResponse>(
362363
'metadata',

0 commit comments

Comments
 (0)