9173825aa6a1525d72a78cda16cb4ae1e9b8a8e4
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute stdProps : Properties to standardProps : Properties in method private printTopic(topicName String, elements int, deserializer DeserializationSchema<?>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Extract Variable | 1 | ||
| Extract Variable val : String in method private getInvalidOffsetBehavior(config Properties) : long from class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher.SimpleConsumerThread | From | To |