From ce90211af6db95982b53f77ee87b3afb3479fb73 Mon Sep 17 00:00:00 2001 From: Jarema Date: Tue, 20 Dec 2022 12:15:51 +0100 Subject: [PATCH] Fix typo in Consumer State Signed-off-by: Jarema --- cli/consumer_command.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cli/consumer_command.go b/cli/consumer_command.go index 2b25e80a..da1059f9 100644 --- a/cli/consumer_command.go +++ b/cli/consumer_command.go @@ -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)))