@@ -1250,7 +1250,7 @@ func testReaderConsumerGroupRebalanceDoesNotCommitNotOwnedPartitions(t *testing.
12501250 require .Eventually (t , func () bool {
12511251 resp , err := client .OffsetFetch (ctx , & OffsetFetchRequest {
12521252 GroupID : firstReader .config .GroupID ,
1253- Topics : map [string ][]int {firstReader .config .Topic : [] int {partitionAssignedToSecondConsumer }},
1253+ Topics : map [string ][]int {firstReader .config .Topic : {partitionAssignedToSecondConsumer }},
12541254 })
12551255 require .NoError (t , err )
12561256 require .NotNil (t , resp )
@@ -1270,7 +1270,7 @@ func testReaderConsumerGroupRebalanceDoesNotCommitNotOwnedPartitions(t *testing.
12701270 require .Eventually (t , func () bool {
12711271 resp , err := client .OffsetFetch (ctx , & OffsetFetchRequest {
12721272 GroupID : firstReader .config .GroupID ,
1273- Topics : map [string ][]int {firstReader .config .Topic : [] int {partitionAssignedToSecondConsumer }},
1273+ Topics : map [string ][]int {firstReader .config .Topic : {partitionAssignedToSecondConsumer }},
12741274 })
12751275 require .NoError (t , err )
12761276 require .NotNil (t , resp )
@@ -1303,7 +1303,7 @@ func testReaderConsumerGroupRebalanceDoesNotCommitNotOwnedPartitions(t *testing.
13031303 require .Eventually (t , func () bool {
13041304 resp , err := client .OffsetFetch (ctx , & OffsetFetchRequest {
13051305 GroupID : firstReader .config .GroupID ,
1306- Topics : map [string ][]int {firstReader .config .Topic : [] int {partitionAssignedToFirstConsumer }},
1306+ Topics : map [string ][]int {firstReader .config .Topic : {partitionAssignedToFirstConsumer }},
13071307 })
13081308 require .NoError (t , err )
13091309 require .NotNil (t , resp )
0 commit comments