2f651e9a69a9929ef154e7bf6fcba624b0e8b9a1
Files Diff
- Added: 14
- Removed: 0
- Renamed: 0
- Modified: 7
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Pull Up Method | 1 | ||
| Pull Up Method private assertAtLeastOnceForTopic(properties Properties, topic String, partition int, expectedElements Set<Integer>, timeoutMillis long) : void from class org.apache.flink.streaming.connectors.kafka.KafkaProducerTestBase to protected assertAtLeastOnceForTopic(properties Properties, topic String, partition int, expectedElements Set<Integer>, timeoutMillis long) : void from class org.apache.flink.streaming.connectors.kafka.KafkaTestBase | From | To |