File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change 11The MIT License (MIT)
2- Copyright (c) 2016-2023 Blizzard Entertainment
3- 2023 Confluent, Inc.
2+ Copyright (c) 2023 Confluent, Inc.
43
54Permission is hereby granted, free of charge, to any person obtaining a copy of
65this software and associated documentation files (the "Software"), to deal in
Original file line number Diff line number Diff line change @@ -213,6 +213,10 @@ class Consumer {
213213 }
214214
215215 if ( Object . hasOwn ( this . #kJSConfig, 'partitionAssignors' ) ) {
216+ if ( ! Array . isArray ( this . #kJSConfig. partitionAssignors ) ) {
217+ throw new error . KafkaJSError ( CompatibilityErrorMessages . partitionAssignors ( ) , { code : error . ErrorCodes . ERR__INVALID_ARG } ) ;
218+ }
219+
216220 this . #kJSConfig. partitionAssignors . forEach ( assignor => {
217221 if ( typeof assignor !== 'string' )
218222 throw new error . KafkaJSError ( CompatibilityErrorMessages . partitionAssignors ( ) , { code : error . ErrorCodes . ERR__INVALID_ARG } ) ;
You can’t perform that action at this time.
0 commit comments