@ovotech/castle
Advanced tools
Comparing version 0.4.1 to 0.4.2
@@ -37,3 +37,3 @@ "use strict"; | ||
producer.on('producer.network.request', () => servicesStatus.set(producer, true)); | ||
const consumers = config.consumers.map(config => { | ||
const consumers = (config.consumers || []).map(config => { | ||
const finalConfig = exports.toFinalCastleConsumerConfig(config); | ||
@@ -40,0 +40,0 @@ const instance = kafka.consumer(finalConfig); |
@@ -39,3 +39,3 @@ import { AvroProducer, AvroEachMessagePayload, AvroEachBatchPayload, SchemaRegistryConfig, AvroConsumer, AvroConsumerRun, AvroMessage, AvroKafka, TopicsAlias } from '@ovotech/avro-kafkajs'; | ||
schemaRegistry: SchemaRegistryConfig; | ||
consumers: CastleConsumerConfig[]; | ||
consumers?: CastleConsumerConfig[]; | ||
} | ||
@@ -42,0 +42,0 @@ export interface CastleService { |
{ | ||
"name": "@ovotech/castle", | ||
"version": "0.4.1", | ||
"version": "0.4.2", | ||
"main": "dist/index.js", | ||
@@ -11,20 +11,20 @@ "types": "dist/index.d.ts", | ||
"devDependencies": { | ||
"@types/jest": "^24.0.24", | ||
"@types/jest": "^25.1.3", | ||
"@types/lodash.chunk": "^4.2.6", | ||
"@types/node": "^13.1.0", | ||
"@types/pg": "^7.14.0", | ||
"@types/uuid": "^3.4.6", | ||
"@typescript-eslint/eslint-plugin": "^2.13.0", | ||
"@typescript-eslint/parser": "^2.13.0", | ||
"@types/node": "^13.7.6", | ||
"@types/pg": "^7.14.1", | ||
"@types/uuid": "^7.0.0", | ||
"@typescript-eslint/eslint-plugin": "^2.21.0", | ||
"@typescript-eslint/parser": "^2.21.0", | ||
"eslint": "^6.8.0", | ||
"eslint-config-prettier": "^6.7.0", | ||
"jest": "^24.9.0", | ||
"pg": "^7.15.1", | ||
"eslint-config-prettier": "^6.10.0", | ||
"jest": "^25.1.0", | ||
"pg": "^7.18.2", | ||
"prettier": "^1.19.1", | ||
"slonik": "^21.4.1", | ||
"ts-jest": "^24.2.0", | ||
"ts-node": "^8.5.4", | ||
"slonik": "^22.4.3", | ||
"ts-jest": "^25.2.1", | ||
"ts-node": "^8.6.2", | ||
"ts-retry-promise": "^0.2.0", | ||
"typescript": "^3.7.4", | ||
"uuid": "^3.3.3", | ||
"typescript": "^3.8.2", | ||
"uuid": "^7.0.1", | ||
"winston": "^3.2.1" | ||
@@ -48,3 +48,3 @@ }, | ||
}, | ||
"gitHead": "d363ab2d4f08bc0ec8b5d6e191068c31909d0480" | ||
"gitHead": "d18201985002154baf896f8717a940c5060e018c" | ||
} |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
25442