File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -1340,7 +1340,7 @@ func TestOffsetStash(t *testing.T) {
1340
1340
Given : offsetStash {},
1341
1341
Messages : []Message {newMessage (0 , 0 )},
1342
1342
Expected : offsetStash {
1343
- topic : {0 : {1 , 1 }},
1343
+ topic : {0 : {1 , 0 }},
1344
1344
},
1345
1345
},
1346
1346
"ignores earlier offsets" : {
@@ -1360,7 +1360,7 @@ func TestOffsetStash(t *testing.T) {
1360
1360
newMessage (0 , 1 ),
1361
1361
},
1362
1362
Expected : offsetStash {
1363
- topic : {0 : {4 , 1 }},
1363
+ topic : {0 : {4 , 0 }},
1364
1364
},
1365
1365
},
1366
1366
"uses latest offset, across multiple topics" : {
@@ -1374,8 +1374,8 @@ func TestOffsetStash(t *testing.T) {
1374
1374
},
1375
1375
Expected : offsetStash {
1376
1376
topic : {
1377
- 0 : {4 , 1 },
1378
- 1 : {7 , 1 },
1377
+ 0 : {4 , 0 },
1378
+ 1 : {7 , 0 },
1379
1379
},
1380
1380
},
1381
1381
},
You can’t perform that action at this time.
0 commit comments