duplicated block id: 1 size: 20 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java (148:184) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (153:189) duplicated block id: 2 size: 19 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java (139:157) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java (108:126) duplicated block id: 3 size: 14 cleaned lines of code in 2 files: - pulsar-client-reactive-producer-cache-caffeine-shaded/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineShadedProducerCacheProvider.java (62:84) - pulsar-client-reactive-producer-cache-caffeine/src/main/java/org/apache/pulsar/reactive/client/producercache/CaffeineProducerCacheProvider.java (65:87) duplicated block id: 4 size: 12 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java (160:173) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java (129:142) duplicated block id: 5 size: 11 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java (120:139) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (126:145) duplicated block id: 6 size: 11 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (538:566) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java (407:435) duplicated block id: 7 size: 11 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java (76:88) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (67:79) duplicated block id: 8 size: 10 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (566:590) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (169:193) duplicated block id: 9 size: 8 cleaned lines of code in 2 files: - idea/codeStyleConfig.xml (29:36) - idea/codeStyleConfig.xml (73:80) duplicated block id: 10 size: 8 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageConsumerE2ETest.java (44:54) - pulsar-client-reactive-adapter/src/intTest/java/org/apache/pulsar/reactive/client/adapter/ReactiveMessageReaderE2ETest.java (42:52) duplicated block id: 11 size: 7 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/DefaultMessageResult.java (45:55) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/internal/api/EmptyMessageResult.java (40:50) duplicated block id: 12 size: 7 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java (365:375) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageSenderSpec.java (271:281) duplicated block id: 13 size: 7 cleaned lines of code in 2 files: - idea/codeStyleConfig.xml (55:61) - idea/codeStyleConfig.xml (78:84) duplicated block id: 14 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (169:182) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java (355:368) duplicated block id: 15 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java (48:54) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSendResult.java (85:91) duplicated block id: 16 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java (143:149) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java (48:54) duplicated block id: 17 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (245:258) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (103:116) duplicated block id: 18 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java (143:149) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSendResult.java (85:91) duplicated block id: 19 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java (61:67) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSendResult.java (85:91) duplicated block id: 20 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java (48:54) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java (61:67) duplicated block id: 21 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (376:390) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (142:156) duplicated block id: 22 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (192:205) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (77:90) duplicated block id: 23 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java (46:52) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java (61:67) duplicated block id: 24 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java (143:149) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageIdStartAtSpec.java (61:67) duplicated block id: 25 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java (46:52) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MessageSendResult.java (85:91) duplicated block id: 26 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (566:579) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageSenderSpec.java (355:368) duplicated block id: 27 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageConsumerSpec.java (375:382) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/ImmutableReactiveMessageReaderSpec.java (121:128) duplicated block id: 28 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/AdaptedReactiveMessageSenderBuilder.java (143:149) - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java (46:52) duplicated block id: 29 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-adapter/src/main/java/org/apache/pulsar/reactive/client/internal/adapter/ProducerCacheKey.java (46:52) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/InstantStartAtSpec.java (48:54) duplicated block id: 30 size: 6 cleaned lines of code in 2 files: - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageConsumerSpec.java (511:524) - pulsar-client-reactive-api/src/main/java/org/apache/pulsar/reactive/client/api/MutableReactiveMessageReaderSpec.java (129:142)