Skip to content

Commit

Permalink
working stub
Browse files Browse the repository at this point in the history
  • Loading branch information
jsumners-nr committed May 29, 2024
1 parent 79e6c77 commit 390227c
Showing 1 changed file with 1 addition and 3 deletions.
4 changes: 1 addition & 3 deletions test/versioned/node-rdkafka/kafka.tap.js
Original file line number Diff line number Diff line change
Expand Up @@ -57,15 +57,13 @@ tap.test('stub', { timeout: 10_000 }, (t) => {
const topic = 'test-topic'

consumer.on('data', (data) => {
console.log('consumed')
t.equal(data.value.toString(), 'test message')
t.end()
})
consumer.subscribe([topic])
consumer.consume()

setTimeout(() => {
console.log('producing')
producer.produce(topic, null, Buffer.from('test message'), 'key')
}, 2000)
}, 500)
})

0 comments on commit 390227c

Please sign in to comment.