wvanbergen/kafka

Go 373 stars

Load-balancing, resuming Kafka consumer for go, backed by Zookeeper.

⟳ Syncing… Share on X →

README badge: [![ngmi](https://ngmi.review/badge/wvanbergen/kafka.svg)](https://ngmi.review/repo/wvanbergen/kafka)

58 Merged PRs

13 days Avg Merge Time

0m Fastest PR

11 months Slowest PR

      #2368
      Global Speed Rank
    

Trim top 0% outliers

Trends Over Time

Monthly aggregates for this repo. The gap between avg and median reveals outlier skew.

PR size over time (lines changed)

Review time over time (hrs)

Changes requested rate over time (%)

Merged PRs per month

Time to first review (hrs)

Unreviewed merge rate (%)

Lines changed (additions + deletions) vs review outcomes.

PRs by size

Avg review time (hrs)

Clean approval rate (%)

#	Title	Author	Time	Reviews	Blocks
#113	break waiting for claiming partition if new consumer join	@mrcold	11 months	1	✓
#105	Fix build on Travis	@wvanbergen	3m	0	✓
#101	Making partitionConsumer claim loop more robust	@rengawm	1 month	0	✓
#104	Support manual committing and optional batching	@JamesOwenHall	3.3h	0	✓
#99	Handle reconnects	@warebot	1 day	0	✓
#93	Complementary fix of partition rebalnce issue(#62)	@caihua-yin	1 month	0	✓
#97	Handle error returned by ReleasePartition() #91	@bhirbec	6 days	0	✓
#92	cg is still nil at this point	@davidreynolds	14.7h	0	✓
#87	Re-register when connection lost/timeout, fixes wvanbergen/kafka#80	@yejingx	3 months	0	✓
#83	Add a configuration setting to call to ResetOffsets on the cg.	@rrh	10 days	0	✓
#78	Skip call to markAsProcessed if the consumer no longer owns the parition	@nemosupremo	10.1h	0	✓
#75	Transfer offsets tool: guard against faulty responses	@wvanbergen	0m	0	✓
#74	Add tool to transfer consumergroup offsets from Zookeeper to Kafka	@wvanbergen	7 days	0	✓
#68	Retry claiming partitions if the partition is already claims. See #62	@nemosupremo	4 days	0	✓
#71	Several small fixes & improvements	@wvanbergen	17m	0	✓
#69	Fix consumergroup example.	@wvanbergen	2m	0	✓
#63	Divide partitions among all consumers. See #61	@nemosupremo	1 month	0	✓
#67	Use default test topics	@wvanbergen	32m	0	✓
#66	Switch sarama imports to github.com path	@aaronkavlie-wf	1 day	0	✓
#57	Handle sarama.ErrOffsetOfRange error somewhat gracefully.	@shivnagarajan	28 days	0	✓