8828648b4f377a97a9aac42365297479054a5ef0
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 1 | ||
| Extract Method public setOffsetsToCommit(offsetsToCommit Map<TopicPartition,OffsetAndMetadata>, commitCallback KafkaCommitCallback) : void extracted from public setOffsetsToCommit(offsetsToCommit Map<TopicPartition,OffsetAndMetadata>) : void in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread | From | To |