Skip to content

Commit 0bc6d56

Browse files
committed
Do not deduplicate topic creations and deletions
As of now creating and deleting multiple topics in a row will ignore most of the topics except the first one. This is due to deduplication that is done based on operation alone without considering the target topics. This change incorporates topic data into the deduplication to avoid the aforementioned issue.
1 parent 4966e07 commit 0bc6d56

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/clients/admin/admin.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -465,7 +465,7 @@ export class Admin extends Base<AdminOptions> {
465465
}
466466

467467
this[kPerformDeduplicated](
468-
'createTopics',
468+
`createTopics-${options.topics.join(',')}`,
469469
deduplicateCallback => {
470470
this[kPerformWithRetry](
471471
'createTopics',
@@ -527,7 +527,7 @@ export class Admin extends Base<AdminOptions> {
527527

528528
#deleteTopics (options: DeleteTopicsOptions, callback: CallbackWithPromise<void>): void {
529529
this[kPerformDeduplicated](
530-
'deleteTopics',
530+
`deleteTopics-${options.topics.join(',')}`,
531531
deduplicateCallback => {
532532
this[kPerformWithRetry](
533533
'deleteTopics',

0 commit comments

Comments
 (0)