From 811094c1cef57136e3cf96c86e225d345bb99135 Mon Sep 17 00:00:00 2001 From: Betsun Vladyslav Date: Tue, 11 Jan 2022 15:19:00 +0200 Subject: [PATCH] fix: accept code-review suggestions --- index.d.ts | 11 ++++++++++- lib/consumer.js | 1 - package.json | 6 +++--- 3 files changed, 13 insertions(+), 5 deletions(-) diff --git a/index.d.ts b/index.d.ts index 0668cb4..506a1b8 100644 --- a/index.d.ts +++ b/index.d.ts @@ -1,6 +1,15 @@ import { FastifyPluginCallback } from 'fastify'; -import { ConsumerGlobalConfig, ConsumerTopicConfig, KafkaConsumer, Message, MetadataOptions, Producer, ProducerGlobalConfig, ProducerTopicConfig } from 'node-rdkafka'; +import { + ConsumerGlobalConfig, + ConsumerTopicConfig, + KafkaConsumer, + Message, + MetadataOptions, + Producer, + ProducerGlobalConfig, + ProducerTopicConfig +} from 'node-rdkafka'; declare module 'fastify' { interface FastifyKafkaMessage extends Pick { diff --git a/lib/consumer.js b/lib/consumer.js index 91218b8..98352f0 100644 --- a/lib/consumer.js +++ b/lib/consumer.js @@ -29,7 +29,6 @@ function Consumer (opts, log, next, topicConf, metadataOptions) { function onReady () { this._log.debug('kafka-consumer:onReady') - if (!calledNext) { calledNext = true return next() diff --git a/package.json b/package.json index b314676..8aed0d1 100644 --- a/package.json +++ b/package.json @@ -32,9 +32,9 @@ "devDependencies": { "@types/node": "^17.0.8", "abstract-logging": "2.0.1", - "fastify": "^3.0.0-rc.2", - "standard": "^16.0.1", - "tap": "^15.1.2", + "fastify": "^3.25.3", + "standard": "^16.0.4", + "tap": "^15.1.6", "tsd": "^0.19.1", "typescript": "^4.5.4" },