Skip to content

Commit 5ea216d

Browse files
committed
Fixes #102
1 parent af49b1c commit 5ea216d

File tree

1 file changed

+6
-7
lines changed

1 file changed

+6
-7
lines changed

README.md

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -392,13 +392,12 @@ This avoids having pending, not stored offsets in case of inactivity. The defau
392392
Those settings are configurable, as shown in the following snippet:
393393
```golang
394394
stream.NewConsumerOptions().
395-
// set a consumerOffsetNumber name
396-
SetConsumerName("my_consumer").
397-
398-
SetAutoCommit(stream.NewAutoCommitStrategy().
399-
SetCountBeforeStorage(50). // store each 50 messages stores
400-
SetFlushInterval(10*time.Second)). // store each 10 seconds
401-
SetOffset(stream.OffsetSpecification{}.First())) // or after 20 seconds
395+
// set a consumerOffsetNumber name
396+
SetConsumerName("my_consumer").
397+
SetAutoCommit(stream.NewAutoCommitStrategy().
398+
SetCountBeforeStorage(50). // store each 50 messages stores
399+
SetFlushInterval(10*time.Second)). // store each 10 seconds
400+
SetOffset(stream.OffsetSpecification{}.First()))
402401
```
403402
404403

0 commit comments

Comments
 (0)