Skip to content

Commit

Permalink
fix: accept code-review suggestions
Browse files Browse the repository at this point in the history
  • Loading branch information
Betsun Vladyslav committed Jan 11, 2022
1 parent 6ebb3b1 commit 811094c
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 5 deletions.
11 changes: 10 additions & 1 deletion index.d.ts
Original file line number Diff line number Diff line change
@@ -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<Message, 'topic' | 'partition' | 'key'> {
Expand Down
1 change: 0 additions & 1 deletion lib/consumer.js
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand Down
6 changes: 3 additions & 3 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -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"
},
Expand Down

0 comments on commit 811094c

Please sign in to comment.