duplicated block id: 1
size: 44 cleaned lines of code
in 2 files:
 - consumer/pull_consumer.go (658:708)
 - consumer/push_consumer.go (442:492)

duplicated block id: 2
size: 11 cleaned lines of code
in 2 files:
 - consumer/pull_consumer.go (745:758)
 - consumer/push_consumer.go (918:931)

duplicated block id: 3
size: 10 cleaned lines of code
in 2 files:
 - consumer/pull_consumer.go (613:625)
 - consumer/push_consumer.go (366:378)

duplicated block id: 4
size: 10 cleaned lines of code
in 2 files:
 - consumer/pull_consumer.go (760:772)
 - consumer/push_consumer.go (933:945)

duplicated block id: 5
size: 6 cleaned lines of code
in 2 files:
 - consumer/pull_consumer.go (987:994)
 - consumer/push_consumer.go (433:440)