Skip to content

Commit

Permalink
Fix typo in Consumer State
Browse files Browse the repository at this point in the history
Signed-off-by: Jarema <melgaer@gmail.com>
  • Loading branch information
Jarema committed Dec 20, 2022
1 parent 760f66b commit ce90211
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions cli/consumer_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -658,9 +658,9 @@ func (c *consumerCmd) showInfo(config api.ConsumerConfig, state api.ConsumerInfo

if config.AckPolicy != api.AckNone {
if state.AckFloor.Last == nil {
fmt.Printf(" Acknowledgment floor: Consumer sequence: %s Stream sequence: %s\n", humanize.Comma(int64(state.AckFloor.Consumer)), humanize.Comma(int64(state.AckFloor.Stream)))
fmt.Printf(" Acknowledgement floor: Consumer sequence: %s Stream sequence: %s\n", humanize.Comma(int64(state.AckFloor.Consumer)), humanize.Comma(int64(state.AckFloor.Stream)))
} else {
fmt.Printf(" Acknowledgment floor: Consumer sequence: %s Stream sequence: %s Last Ack: %s ago\n", humanize.Comma(int64(state.AckFloor.Consumer)), humanize.Comma(int64(state.AckFloor.Stream)), humanizeDuration(time.Since(*state.AckFloor.Last)))
fmt.Printf(" Acknowledgement floor: Consumer sequence: %s Stream sequence: %s Last Ack: %s ago\n", humanize.Comma(int64(state.AckFloor.Consumer)), humanize.Comma(int64(state.AckFloor.Stream)), humanizeDuration(time.Since(*state.AckFloor.Last)))
}
if config.MaxAckPending > 0 {
fmt.Printf(" Outstanding Acks: %s out of maximum %s\n", humanize.Comma(int64(state.NumAckPending)), humanize.Comma(int64(config.MaxAckPending)))
Expand Down

0 comments on commit ce90211

Please sign in to comment.