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 c12f6b8
Show file tree
Hide file tree
Showing 4 changed files with 14 additions and 6 deletions.
6 changes: 3 additions & 3 deletions .github/workflows/ci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -24,12 +24,12 @@ jobs:
uses: actions/setup-node@v2
with:
node-version: ${{ matrix.node-version }}
- name: Start Infrastructure
run: |
docker-compose up -d
- name: Install Dependencies
run: |
npm install
- name: Start Infrastructure
run: |
docker-compose up -d
- name: Run Tests
run: |
npm test
Expand Down
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
2 changes: 1 addition & 1 deletion package.json
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
"abstract-logging": "2.0.1",
"fastify": "^3.0.0-rc.2",
"standard": "^16.0.1",
"tap": "^15.1.2",
"tap": "^15.1.6",
"tsd": "^0.19.1",
"typescript": "^4.5.4"
},
Expand Down

0 comments on commit c12f6b8

Please sign in to comment.