issues
search
Shopify
/
camus
Kafka->HDFS pipeline from LInkedIn. It is a mapreduce job that does distributed data loads out of Kafka.
7
stars
4
forks
source link
Add statsd metrics with topic and patition tags
#91
Closed
olessia
closed
6 years ago
olessia
commented
6 years ago
count of new messages to process (as a diff between current and latest offsets)
count of messages read
number of times the the pull reaches maximum allowed run time
Review: @dterror
Review: @dterror