duplicated block id: 1
size: 12 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (221:237)
 - pulsar/consumer_regex.go (243:259)

duplicated block id: 2
size: 11 cleaned lines of code
in 2 files:
 - pulsar/consumer_impl.go (278:289)
 - pulsar/producer_impl.go (164:175)

duplicated block id: 3
size: 11 cleaned lines of code
in 2 files:
 - pulsar/consumer_partition.go (492:508)
 - pulsar/consumer_partition.go (923:939)

duplicated block id: 4
size: 10 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (153:166)
 - oauth2/authorization_tokenretriever.go (208:221)

duplicated block id: 5
size: 10 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (153:166)
 - oauth2/authorization_tokenretriever.go (177:190)

duplicated block id: 6
size: 10 cleaned lines of code
in 2 files:
 - pulsar/consumer_impl.go (467:477)
 - pulsar/consumer_multitopic.go (101:111)

duplicated block id: 7
size: 10 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (177:190)
 - oauth2/authorization_tokenretriever.go (208:221)

duplicated block id: 8
size: 10 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (129:142)
 - oauth2/authorization_tokenretriever.go (153:166)

duplicated block id: 9
size: 10 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (101:111)
 - pulsar/consumer_regex.go (141:151)

duplicated block id: 10
size: 10 cleaned lines of code
in 2 files:
 - pulsar/consumer_impl.go (467:477)
 - pulsar/consumer_regex.go (141:151)

duplicated block id: 11
size: 10 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (129:142)
 - oauth2/authorization_tokenretriever.go (177:190)

duplicated block id: 12
size: 10 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (129:142)
 - oauth2/authorization_tokenretriever.go (208:221)

duplicated block id: 13
size: 9 cleaned lines of code
in 2 files:
 - pulsar/consumer_partition.go (1169:1177)
 - pulsar/consumer_partition.go (1189:1197)

duplicated block id: 14
size: 8 cleaned lines of code
in 2 files:
 - pulsar/producer_partition.go (713:720)
 - pulsar/producer_partition.go (819:827)

duplicated block id: 15
size: 8 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (241:252)
 - pulsar/consumer_regex.go (263:275)

duplicated block id: 16
size: 8 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (128:139)
 - pulsar/consumer_multitopic.go (172:183)

duplicated block id: 17
size: 8 cleaned lines of code
in 2 files:
 - pulsar/log/logger.go (42:50)
 - pulsar/log/logger.go (58:66)

duplicated block id: 18
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (176:187)
 - pulsar/consumer_regex.go (228:239)

duplicated block id: 19
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (223:231)
 - pulsar/consumer_regex.go (263:272)

duplicated block id: 20
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (258:265)
 - pulsar/consumer_regex.go (286:293)

duplicated block id: 21
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (241:249)
 - pulsar/consumer_regex.go (245:253)

duplicated block id: 22
size: 7 cleaned lines of code
in 2 files:
 - pulsar/producer_partition.go (1252:1258)
 - pulsar/producer_partition.go (1261:1267)

duplicated block id: 23
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_regex.go (245:253)
 - pulsar/consumer_regex.go (263:272)

duplicated block id: 24
size: 7 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (181:190)
 - oauth2/device_code_provider.go (111:120)

duplicated block id: 25
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (128:136)
 - pulsar/consumer_multitopic.go (149:157)

duplicated block id: 26
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (149:157)
 - pulsar/consumer_multitopic.go (172:180)

duplicated block id: 27
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_regex.go (177:186)
 - pulsar/consumer_regex.go (199:208)

duplicated block id: 28
size: 7 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (133:142)
 - oauth2/device_code_provider.go (111:120)

duplicated block id: 29
size: 7 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (157:166)
 - oauth2/device_code_provider.go (111:120)

duplicated block id: 30
size: 7 cleaned lines of code
in 2 files:
 - pulsar/internal/batch_builder.go (192:204)
 - pulsar/internal/key_based_batch_builder.go (138:149)

duplicated block id: 31
size: 7 cleaned lines of code
in 2 files:
 - pulsar/consumer_multitopic.go (223:231)
 - pulsar/consumer_multitopic.go (241:249)

duplicated block id: 32
size: 7 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (212:221)
 - oauth2/device_code_provider.go (111:120)

duplicated block id: 33
size: 7 cleaned lines of code
in 2 files:
 - pulsar/internal/batch_builder.go (50:56)
 - pulsar/internal/key_based_batch_builder.go (131:137)

duplicated block id: 34
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (864:869)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (898:903)

duplicated block id: 35
size: 6 cleaned lines of code
in 2 files:
 - pulsar/negative_acks_tracker.go (74:83)
 - pulsar/negative_acks_tracker.go (100:109)

duplicated block id: 36
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (915:920)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (932:937)

duplicated block id: 37
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (849:854)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (915:920)

duplicated block id: 38
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (864:869)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (883:888)

duplicated block id: 39
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (849:854)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (932:937)

duplicated block id: 40
size: 6 cleaned lines of code
in 2 files:
 - pulsar/consumer_partition.go (2120:2125)
 - pulsar/consumer_partition.go (2161:2166)

duplicated block id: 41
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/lookup_service.go (184:191)
 - pulsar/internal/lookup_service.go (323:330)

duplicated block id: 42
size: 6 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (200:210)
 - oauth2/device_code_provider.go (101:109)

duplicated block id: 43
size: 6 cleaned lines of code
in 2 files:
 - pulsar/consumer_regex.go (177:185)
 - pulsar/consumer_regex.go (223:231)

duplicated block id: 44
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (883:888)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (898:903)

duplicated block id: 45
size: 6 cleaned lines of code
in 2 files:
 - pulsar/consumer_regex.go (199:207)
 - pulsar/consumer_regex.go (223:231)

duplicated block id: 46
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (849:854)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (864:869)

duplicated block id: 47
size: 6 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (228:237)
 - oauth2/authorization_tokenretriever.go (343:352)

duplicated block id: 48
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (864:869)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (932:937)

duplicated block id: 49
size: 6 cleaned lines of code
in 2 files:
 - pulsar/consumer_partition.go (1013:1018)
 - pulsar/consumer_partition.go (1184:1189)

duplicated block id: 50
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (849:854)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (883:888)

duplicated block id: 51
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (883:888)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (915:920)

duplicated block id: 52
size: 6 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (327:336)
 - oauth2/authorization_tokenretriever.go (343:352)

duplicated block id: 53
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (864:869)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (915:920)

duplicated block id: 54
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (898:903)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (915:920)

duplicated block id: 55
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (849:854)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (898:903)

duplicated block id: 56
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (883:888)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (932:937)

duplicated block id: 57
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/pulsar_proto/PulsarApi.proto (898:903)
 - pulsar/internal/pulsar_proto/PulsarApi.proto (932:937)

duplicated block id: 58
size: 6 cleaned lines of code
in 2 files:
 - pulsar/internal/rpc_client.go (125:131)
 - pulsar/internal/rpc_client.go (157:163)

duplicated block id: 59
size: 6 cleaned lines of code
in 2 files:
 - oauth2/authorization_tokenretriever.go (228:237)
 - oauth2/authorization_tokenretriever.go (327:336)