Update smq_mapping_test.go

2 months ago · c951fc03c1
1 changed files with 1 additions and 1 deletions
--- a/weed/mq/kafka/offset/smq_mapping_test.go
+++ b/weed/mq/kafka/offset/smq_mapping_test.go
@ -115,7 +115,7 @@ func TestCreateSMQSubscriptionRequest(t *testing.T) {
 		assert.Equal(t, schema_pb.OffsetType_EXACT_TS_NS, offsetType)
 		assert.Equal(t, baseTime+2000, partitionOffset.StartTsNs)
 		assert.Equal(t, int32(0), partitionOffset.Partition.RangeStart)
-		assert.Equal(t, int32(31), partitionOffset.Partition.RangeStop)
+		assert.Equal(t, int32(77), partitionOffset.Partition.RangeStop)

 		t.Logf("Specific offset 2 → SMQ timestamp %d", partitionOffset.StartTsNs)
 	})