7a5ec023f3cb2d9ac619916bf920009d43f5c449
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type consumerCallBridge : KafkaConsumerCallBridge to consumerCallBridge : KafkaConsumerCallBridge09 in method public KafkaConsumerThread(log Logger, handover Handover, kafkaProperties Properties, unassignedPartitionsQueue ClosableBlockingQueue<KafkaTopicPartitionState<TopicPartition>>, consumerCallBridge KafkaConsumerCallBridge09, threadName String, pollTimeout long, useMetrics boolean, consumerMetricGroup MetricGroup, subtaskMetricGroup MetricGroup) in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread | From | To | |
| Change Return Type | 1 | ||
| Change Return Type KafkaConsumerCallBridge to KafkaConsumerCallBridge09 in method protected createCallBridge() : KafkaConsumerCallBridge09 in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerCallBridge renamed to org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerCallBridge09 | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type consumerCallBridge : KafkaConsumerCallBridge to consumerCallBridge : KafkaConsumerCallBridge09 in class org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread | From | To |