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) {
13401340 Given : offsetStash {},
13411341 Messages : []Message {newMessage (0 , 0 )},
13421342 Expected : offsetStash {
1343- topic : {0 : {1 , 1 }},
1343+ topic : {0 : {1 , 0 }},
13441344 },
13451345 },
13461346 "ignores earlier offsets" : {
@@ -1360,7 +1360,7 @@ func TestOffsetStash(t *testing.T) {
13601360 newMessage (0 , 1 ),
13611361 },
13621362 Expected : offsetStash {
1363- topic : {0 : {4 , 1 }},
1363+ topic : {0 : {4 , 0 }},
13641364 },
13651365 },
13661366 "uses latest offset, across multiple topics" : {
@@ -1374,8 +1374,8 @@ func TestOffsetStash(t *testing.T) {
13741374 },
13751375 Expected : offsetStash {
13761376 topic : {
1377- 0 : {4 , 1 },
1378- 1 : {7 , 1 },
1377+ 0 : {4 , 0 },
1378+ 1 : {7 , 0 },
13791379 },
13801380 },
13811381 },
You can’t perform that action at this time.
0 commit comments