Skip to content

Commit 9fb2203

Browse files
committed
Change fromBeginning in sr.js example
1 parent 58c3449 commit 9fb2203

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

examples/kafkajs/sr.js

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ const kafka = new Kafka({
2222
let consumer = kafka.consumer({
2323
kafkaJS: {
2424
groupId: "test-group",
25-
fromBeginning: false,
25+
fromBeginning: true,
2626
},
2727
});
2828
let producer = kafka.producer();

0 commit comments

Comments
 (0)