Skip to content

Commit

Permalink
Fix linter
Browse files Browse the repository at this point in the history
  • Loading branch information
onurtemizkan committed Aug 29, 2024
1 parent 559f53a commit 0811839
Showing 1 changed file with 7 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,15 @@ async function run() {
});

const consumer = kafka.consumer({
groupId: 'test-group'
groupId: 'test-group',
});

await consumer.connect();
await consumer.subscribe({ topic: 'test-topic', fromBeginning: true });

consumer.run({
eachMessage: async ({ message }) => {
// eslint-disable-next-line no-console
console.debug('Received message', message.value.toString());
},
});
Expand All @@ -47,9 +48,11 @@ async function run() {

await producer.send({
topic: 'test-topic',
messages: [{
value: 'TEST_MESSAGE',
}],
messages: [
{
value: 'TEST_MESSAGE',
},
],
});

// Wait for the message to be received
Expand Down

0 comments on commit 0811839

Please sign in to comment.