@@ -1250,7 +1250,7 @@ func testReaderConsumerGroupRebalanceDoesNotCommitNotOwnedPartitions(t *testing.
1250
1250
require .Eventually (t , func () bool {
1251
1251
resp , err := client .OffsetFetch (ctx , & OffsetFetchRequest {
1252
1252
GroupID : firstReader .config .GroupID ,
1253
- Topics : map [string ][]int {firstReader .config .Topic : [] int {partitionAssignedToSecondConsumer }},
1253
+ Topics : map [string ][]int {firstReader .config .Topic : {partitionAssignedToSecondConsumer }},
1254
1254
})
1255
1255
require .NoError (t , err )
1256
1256
require .NotNil (t , resp )
@@ -1270,7 +1270,7 @@ func testReaderConsumerGroupRebalanceDoesNotCommitNotOwnedPartitions(t *testing.
1270
1270
require .Eventually (t , func () bool {
1271
1271
resp , err := client .OffsetFetch (ctx , & OffsetFetchRequest {
1272
1272
GroupID : firstReader .config .GroupID ,
1273
- Topics : map [string ][]int {firstReader .config .Topic : [] int {partitionAssignedToSecondConsumer }},
1273
+ Topics : map [string ][]int {firstReader .config .Topic : {partitionAssignedToSecondConsumer }},
1274
1274
})
1275
1275
require .NoError (t , err )
1276
1276
require .NotNil (t , resp )
@@ -1303,7 +1303,7 @@ func testReaderConsumerGroupRebalanceDoesNotCommitNotOwnedPartitions(t *testing.
1303
1303
require .Eventually (t , func () bool {
1304
1304
resp , err := client .OffsetFetch (ctx , & OffsetFetchRequest {
1305
1305
GroupID : firstReader .config .GroupID ,
1306
- Topics : map [string ][]int {firstReader .config .Topic : [] int {partitionAssignedToFirstConsumer }},
1306
+ Topics : map [string ][]int {firstReader .config .Topic : {partitionAssignedToFirstConsumer }},
1307
1307
})
1308
1308
require .NoError (t , err )
1309
1309
require .NotNil (t , resp )
0 commit comments