Comparing version
{ | ||
"name": "kafkajs", | ||
"version": "1.15.0-beta.6", | ||
"version": "1.15.0-beta.7", | ||
"description": "A modern Apache Kafka client for node.js", | ||
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <ornelas.tulio@gmail.com>", | ||
"kafkajs": { | ||
"sha": "f9d7dfec0f4d3735d6ba459795582116bd6567f6", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...f9d7dfec0f4d3735d6ba459795582116bd6567f6" | ||
"sha": "900c60a7473d16b7f678be4284ed95f21587b789", | ||
"compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...900c60a7473d16b7f678be4284ed95f21587b789" | ||
} | ||
} |
@@ -10,3 +10,2 @@ const createRetry = require('../retry') | ||
const { KafkaJSNonRetriableError, KafkaJSDeleteGroupsError } = require('../errors') | ||
const RESOURCE_TYPES = require('../protocol/resourceTypes') | ||
const CONFIG_RESOURCE_TYPES = require('../protocol/configResourceTypes') | ||
@@ -634,3 +633,3 @@ const { EARLIEST_OFFSET, LATEST_OFFSET } = require('../constants') | ||
const validResourceTypes = Object.values(RESOURCE_TYPES) | ||
const validResourceTypes = Object.values(CONFIG_RESOURCE_TYPES) | ||
const invalidType = resources.find(r => !validResourceTypes.includes(r.type)) | ||
@@ -637,0 +636,0 @@ |
601381
-0.01%17723
-0.01%