e249493b7e3a5a5cae4e5a779b9499caccd6324a
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type record : ConsumerRecord<String,V> to record : ConsumerRecord<byte[],byte[]> in method public KafkaRecord(record ConsumerRecord<byte[],byte[]>, value V) in class org.apache.pulsar.io.kafka.KafkaSource.KafkaRecord | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type consumer : Consumer<String,V> to consumer : Consumer<byte[],byte[]> in class org.apache.pulsar.io.kafka.KafkaSource | From | To | |
| Change Attribute Type record : ConsumerRecord<String,V> to record : ConsumerRecord<byte[],byte[]> in class org.apache.pulsar.io.kafka.KafkaSource.KafkaRecord | From | To |