Chia-Ping Tsai created KAFKA-16610:
--------------------------------------
Summary: Replace "Map#entrySet#forEach" by "Map#forEach"
Key: KAFKA-16610
URL: https://issues.apache.org/jira/browse/KAFKA-16610
Project: Kafka
Issue Type: Improvement
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{quote}
Targets
Occurrences of 'entrySet().forEach' in Project
Found occurrences in Project (16 usages found)
Unclassified (16 usages found)
kafka.core.main (9 usages found)
kafka.server (4 usages found)
ControllerApis.scala (2 usages found)
ControllerApis (2 usages found)
handleIncrementalAlterConfigs (1 usage found)
774 controllerResults.entrySet().forEach(entry =>
response.responses().add(
handleLegacyAlterConfigs (1 usage found)
533 controllerResults.entrySet().forEach(entry =>
response.responses().add(
ControllerConfigurationValidator.scala (2 usages found)
ControllerConfigurationValidator (2 usages found)
validate (2 usages found)
99 config.entrySet().forEach(e => {
114 config.entrySet().forEach(e =>
properties.setProperty(e.getKey, e.getValue))
kafka.server.metadata (5 usages found)
AclPublisher.scala (1 usage found)
AclPublisher (1 usage found)
onMetadataUpdate (1 usage found)
73 aclsDelta.changes().entrySet().forEach(e =>
ClientQuotaMetadataManager.scala (3 usages found)
ClientQuotaMetadataManager (3 usages found)
handleIpQuota (1 usage found)
119 quotaDelta.changes().entrySet().forEach { e =>
update (2 usages found)
54 quotasDelta.changes().entrySet().forEach { e =>
99 quotaDelta.changes().entrySet().forEach { e =>
KRaftMetadataCache.scala (1 usage found)
KRaftMetadataCache (1 usage found)
getClusterMetadata (1 usage found)
491 topic.partitions().entrySet().forEach { entry =>
kafka.core.test (1 usage found)
unit.kafka.integration (1 usage found)
KafkaServerTestHarness.scala (1 usage found)
KafkaServerTestHarness (1 usage found)
getTopicNames (1 usage found)
349
controllerServer.controller.findAllTopicIds(ANONYMOUS_CONTEXT).get().entrySet().forEach
{
kafka.metadata.main (3 usages found)
org.apache.kafka.controller (2 usages found)
QuorumFeatures.java (1 usage found)
toString() (1 usage found)
144 localSupportedFeatures.entrySet().forEach(f ->
features.add(f.getKey() + ": " + f.getValue()));
ReplicationControlManager.java (1 usage found)
createTopic(ControllerRequestContext, CreatableTopic,
List<ApiMessageAndVersion>, Map<String, CreatableTopicResult>,
List<ApiMessageAndVersion>, boolean) (1 usage found)
732 newParts.entrySet().forEach(e ->
assignments.put(e.getKey(),
org.apache.kafka.metadata.properties (1 usage found)
MetaPropertiesEnsemble.java (1 usage found)
toString() (1 usage found)
610 logDirProps.entrySet().forEach(
kafka.metadata.test (1 usage found)
org.apache.kafka.controller (1 usage found)
ReplicationControlManagerTest.java (1 usage found)
createTestTopic(String, int[][], Map<String, String>,
short) (1 usage found)
307 configs.entrySet().forEach(e -> topic.configs().add(
kafka.streams.main (1 usage found)
org.apache.kafka.streams.processor.internals (1 usage found)
StreamsMetadataState.java (1 usage found)
onChange(Map<HostInfo, Set<TopicPartition>>, Map<HostInfo,
Set<TopicPartition>>, Map<TopicPartition, PartitionInfo>) (1 usage found)
317 topicPartitionInfo.entrySet().forEach(entry ->
this.partitionsByTopic
kafka.tools.main (1 usage found)
org.apache.kafka.tools (1 usage found)
LeaderElectionCommand.java (1 usage found)
electLeaders(Admin, ElectionType,
Optional<Set<TopicPartition>>) (1 usage found)
178 failed.entrySet().forEach(entry -> {
{quote}
origin discussion:
[https://github.com/apache/kafka/pull/15786#discussion_r1577656938]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
