[KAFKA-12235] ZkAdminManager.describeConfigs returns no config when 2+ configuration keys are specified

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.7.0
• Fix Version/s: 2.8.0, 2.7.1
• Component/s: core
• Labels: regression
• Assignee: Ivan Yurchenko
• Reporter: Ivan Yurchenko
• Reviewer: Colin McCabe
• Created: 25/Jan/21 15:15
• Updated: 26/Feb/21 20:09
• Resolved: 26/Feb/21 20:09

Description

When ZkAdminManager.describeConfigs receives DescribeConfigsResource with 2 or more configurationKeys specified, it returns an empty configuration.

Here's a test for ZkAdminManagerTest that reproduces this issue:
 

@Test
def testDescribeConfigsWithConfigurationKeys(): Unit = {
  EasyMock.expect(zkClient.getEntityConfigs(ConfigType.Topic, topic)).andReturn(TestUtils.createBrokerConfig(brokerId, "zk"))
  EasyMock.expect(metadataCache.contains(topic)).andReturn(true)

  EasyMock.replay(zkClient, metadataCache)

  val resources = List(new DescribeConfigsRequestData.DescribeConfigsResource()
    .setResourceName(topic)
    .setResourceType(ConfigResource.Type.TOPIC.id)
    .setConfigurationKeys(List("retention.ms", "retention.bytes", "segment.bytes").asJava)
  )

  val adminManager = createAdminManager()
  val results: List[DescribeConfigsResponseData.DescribeConfigsResult] = adminManager.describeConfigs(resources, true, true)
  assertEquals(Errors.NONE.code, results.head.errorCode())
  val resultConfigKeys = results.head.configs().asScala.map(r => r.name()).toSet
  assertEquals(Set("retention.ms", "retention.bytes", "segment.bytes"), resultConfigKeys)
}

Works fine with one configuration key, though.

The patch is following shortly.

Issue Links

• links to: GitHub Pull Request #9990