bugfix-RND-458-consumre-last-messages-start-from-seq-not-working-as-expected

README.md

@@ -747,6 +747,10 @@ func handler(msgs []*memphis.Msg, err error, ctx context.Context) {
 consumer.Consume(handler, 
 				memphis.ConsumerPartitionKey(<string>) // use the partition key to consume from a spacific partition (if not specified consume in a Round Robin fashion)
 )
+
+consumer.Consume(handler, 
+				memphis.ConsumerPartitionNumber(<string>) 
+)
 ```
 
 #### Consumer schema deserialization
@@ -780,6 +784,7 @@ msgs, err := conn.FetchMessages("<station-name>", "<consumer-name>",
   memphis.FetchStartConsumeFromSeq(<uint64>)// start consuming from a specific sequence. defaults to 1
   memphis.FetchLastMessages(<int64>)// consume the last N messages, defaults to -1 (all messages in the station))
   memphis.FetchPartitionKey(<string>)// use the partition key to consume from a spacific partition (if not specified consume in a Round Robin fashion)
+)
 ```
 
 ### Fetch a single batch of messages after creating a consumer

connect.go

@@ -15,7 +15,7 @@
 package memphis
 
 import (
 	"context"
 	"crypto/rand"
 	"crypto/tls"
 	"crypto/x509"
@@ -31,10 +31,10 @@
 	"sync"
 	"time"
 
 	"github.com/gofrs/uuid"
 	"github.com/nats-io/nats.go"
 	"github.com/nats-io/nats.go/jetstream"
 	"github.com/spaolacci/murmur3"
 )
 
 const (
@@ -983,7 +983,7 @@
 }
 
 func (c *Conn) ValidatePartitionNumber(partitionNumber int, stationName string) error {
-	if partitionNumber < 0 || partitionNumber >= len(c.stationPartitions[stationName].PartitionsList) {
+	if partitionNumber < 0 || partitionNumber > len(c.stationPartitions[stationName].PartitionsList) {
 		return errors.New("Partition number is out of range")
 	}
 	for _, partition := range c.stationPartitions[stationName].PartitionsList {