diff --git a/src/clients/admin/admin.ts b/src/clients/admin/admin.ts index 1bddabd..5384954 100644 --- a/src/clients/admin/admin.ts +++ b/src/clients/admin/admin.ts @@ -465,7 +465,7 @@ export class Admin extends Base { } this[kPerformDeduplicated]( - 'createTopics', + `createTopics-${options.topics.join(',')}`, deduplicateCallback => { this[kPerformWithRetry]( 'createTopics', @@ -527,7 +527,7 @@ export class Admin extends Base { #deleteTopics (options: DeleteTopicsOptions, callback: CallbackWithPromise): void { this[kPerformDeduplicated]( - 'deleteTopics', + `deleteTopics-${options.topics.join(',')}`, deduplicateCallback => { this[kPerformWithRetry]( 'deleteTopics',