cb34e976d7c71e87a3fd8c4902f761c70cc453ec
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method public getTopicInfo(topicName String) : TopicMetadata renamed to private getTopicMetadataWithErrorCode(topicName String) : TopicMetadata in class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicUtils | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type a_oldLeader : String to a_oldLeader : Broker in method private findNewLeader(a_oldLeader Broker, a_topic String, a_partition int) : Broker in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Variable | 1 | ||
| Rename Variable brokerAddress : String to listOfBrokers : String in method public open(configuration Configuration) : void in class org.apache.flink.streaming.connectors.kafka.api.KafkaSink | From | To | |
| Change Return Type | 1 | ||
| Change Return Type String to Broker in method private findNewLeader(a_oldLeader Broker, a_topic String, a_partition int) : Broker in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.connectors.kafka.KafkaITCase.LocalSystemTime moved and renamed to org.apache.flink.streaming.connectors.kafka.util.KafkaLocalSystemTime | From | To | |
| Extract Method | 1 | ||
| Extract Method private findNewLeader() : void extracted from private resetFetchResponse(offset long) : void in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type leadBroker : String to leadBroker : Broker in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter a_hosts : List<String> to addresses : List<String> in method private findLeader(addresses List<String>, a_topic String, a_partition int) : PartitionMetadata in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To |