fix(test): align suppressedHighWaterMarkOffset

Signed-off-by: Dominic Evans <[email protected]>
fimars · Apr 25, 2024 · ae43c54 · ae43c54
1 parent 33d24da
commit ae43c54
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/mocks/consumer.go b/mocks/consumer.go
@@ -248,14 +248,14 @@ func (c *Consumer) ExpectConsumePartition(topic string, partition int32, offset
 // channels using YieldMessage and YieldError.
 type PartitionConsumer struct {
 	highWaterMarkOffset           int64 // must be at the top of the struct because https://golang.org/pkg/sync/atomic/#pkg-note-BUG
+	suppressedHighWaterMarkOffset int64
 	l                             sync.Mutex
 	t                             ErrorReporter
 	topic                         string
 	partition                     int32
 	offset                        int64
 	messages                      chan *sarama.ConsumerMessage
 	suppressedMessages            chan *sarama.ConsumerMessage
-	suppressedHighWaterMarkOffset int64
 	errors                        chan *sarama.ConsumerError
 	singleClose                   sync.Once
 	consumed                      bool