Skip to content
This repository has been archived by the owner on May 13, 2019. It is now read-only.

consumption message delay #116

Open
orange-jacky opened this issue Apr 1, 2017 · 0 comments
Open

consumption message delay #116

orange-jacky opened this issue Apr 1, 2017 · 0 comments

Comments

@orange-jacky
Copy link

orange-jacky commented Apr 1, 2017

hi,anyone
I create a consumergroup to consumer some topics, and I print offset of each topic, and find some topic consumption delay.
Meanwhile, i create a consumergroup with "github.com/Shopify/sarama", and find topic is normal consumption.
Anyone can help me fix the issue?

tips:

**normal consumption source code**

kafka.go.zip

**consumption delay source code**
kafka_0.8.2_group.go.zip
delay_log.txt

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant