Skip to content

Commit

Permalink
Add annotation to StartMessageIDInclusive
Browse files Browse the repository at this point in the history
  • Loading branch information
shibd committed Mar 6, 2025
1 parent d40753a commit a232514
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 0 deletions.
1 change: 1 addition & 0 deletions pulsar/consumer.go
Original file line number Diff line number Diff line change
Expand Up @@ -261,6 +261,7 @@ type ConsumerOptions struct {
SubscriptionMode SubscriptionMode

// StartMessageIDInclusive, if true, the consumer will start at the `StartMessageID`, included.
// Note: This configuration also affects the seek operation.
// Default is `false` and the consumer will start from the "next" message
StartMessageIDInclusive bool

Expand Down
1 change: 1 addition & 0 deletions pulsar/reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,7 @@ type ReaderOptions struct {
StartMessageID MessageID

// StartMessageIDInclusive, if true, the reader will start at the `StartMessageID`, included.
// Note: This configuration also affects the seek operation.
// Default is `false` and the reader will start from the "next" message
StartMessageIDInclusive bool

Expand Down

0 comments on commit a232514

Please sign in to comment.