Merge remote-tracking branch 'tulios_kafkajs/master'

tulios · Nov 4, 2020 · 643f6bc · 643f6bc
2 parents 02e5dd0 + 668b85e
commit 643f6bc
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/src/consumer/consumerGroup.js b/src/consumer/consumerGroup.js
@@ -98,7 +98,7 @@ module.exports = class ConsumerGroup {
      * Each of the partitions tracks the preferred read replica (`nodeId`) and a timestamp
      * until when that preference is valid.
      *
-     * @type {{[topicName: string]: {[partition: number]: {nodeId: number, expireAt: number}}}
+     * @type {{[topicName: string]: {[partition: number]: {nodeId: number, expireAt: number}}}}
      */
     this.preferredReadReplicasPerTopicPartition = {}
     this.offsetManager = null

diff --git a/types/index.d.ts b/types/index.d.ts
@@ -370,7 +370,7 @@ export interface AclResource {
 export type AclEntry = Acl & AclResource
 
 export type DescribeAclResource = AclResource & {
-  acls: Acl[]
+  acl: Acl[]
 }
 
 export interface DescribeAclResponse {
@@ -454,7 +454,7 @@ export type Admin = {
   describeGroups(groupIds: string[]): Promise<GroupDescriptions>
   describeAcls(options: AclFilter): Promise<DescribeAclResponse>
   deleteAcls(options: { filters: AclFilter[] }): Promise<DeleteAclResponse>
-  createAcls(options: { acls: AclEntry[] }): Promise<boolean>
+  createAcls(options: { acl: AclEntry[] }): Promise<boolean>
   deleteTopicRecords(options: { topic: string; partitions: SeekEntry[] }): Promise<void>
   logger(): Logger
   on(

diff --git a/types/tests.ts b/types/tests.ts
@@ -220,12 +220,12 @@ const runAdmin = async () => {
       resourceType: r.resourceType,
       resourceName: r.resourceName,
       resourcePatternType: r.resourcePatternType,
-      acls: r.acls,
+      acls: r.acl,
     })),
   })
 
   const createAcls = await admin.createAcls({
-    acls: [
+    acl: [
       {
         resourceType: AclResourceTypes.TOPIC,
         resourceName: 'topic-name',