wvanbergen kafka issues

wvanbergen / kafka

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

MIT License

373 stars 143 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

add function that get consumer by brokers

#132 zhangkyou opened 5 years ago
0
check whether comsumer subscript the topic or not when divide partiti…

#131 xiejq1990 opened 5 years ago
0
Is there any way to get to the ConsumerGroup. Instance. ID？

#130 yjp211 opened 5 years ago
0
which tag or version support kafka 0.8 ?

#129 inolddays closed 5 years ago
0
Version releases?

#128 natdm opened 6 years ago
2
ConsumerGroup.FlushOffsets()

#127 wangping886 closed 6 years ago
3
Can't receive messages when i test the demo which the project gives.

#126 runnerliu closed 6 years ago
4
Leader change during re-balance may cause partition not being consumed

#125 waterlx opened 6 years ago
4
Kafka consumer not restarting after broker failure

#124 bidesh opened 6 years ago
0
Upgrading to kafka based offset storage

#123 sagard closed 6 years ago
1
Trouble reliably reusing consumer group names across topics

#122 mcandre opened 6 years ago
1
Some problems when I try to run my consumer in two node.

#121 HouLinwei closed 6 years ago
3
add filter before send message to queue

#120 ikenchina opened 6 years ago
0
Consumer group not consuming from partitions -- Kafka v11

#119 arriqaaq opened 6 years ago
0
producer configuration update in sync mode

#118 yrong opened 7 years ago
0
consumergroup not work in docker

#117 weisd opened 7 years ago
1
consumption message delay

#116 orange-jacky opened 7 years ago
0
Clarify Kafka version support

#115 mcandre closed 7 years ago
3
How to exit the program in kafka/examples/consumergroup/main.go gracefully?

#114 alexkkk opened 7 years ago
1
break waiting for claiming partition if new consumer join

#113 mrcold closed 6 years ago
3
Mingmin/fork

#112 mmchen closed 7 years ago
0
ConsumerGroup.Messages()

#111 orange-jacky opened 7 years ago
3
Bug? Consuming stops or hangs at certain time.

#110 windless0530 opened 7 years ago
0
Lots of logs such as "abandoned subscription to xxx because consuming was taking too long"

#109 sparkthu closed 7 years ago
1
Is There Any Benchmark for the Consumer?

#108 sparkthu opened 7 years ago
1
zk: node does not exist

#107 sparkthu closed 7 years ago
1
The best practice of handling offsets of asynchronous consuming?

#106 asaarashi closed 7 years ago
6
Fix build on Travis

#105 wvanbergen closed 7 years ago
0
Support manual committing and optional batching

#104 JamesOwenHall closed 7 years ago
5
Trigger rebalance after claim partition failed

#103 Huang-lin opened 7 years ago
0
some partitions have no owner

#102 Huang-lin opened 7 years ago
4
Making partitionConsumer claim loop more robust

#101 rengawm closed 7 years ago
2
how to disable rebalance?

#100 lovestorm88 closed 7 years ago
1
Handle reconnects

#99 warebot closed 8 years ago
5
Handle reconnects [WIP]

#98 warebot closed 8 years ago
1
Handle error returned by ReleasePartition() #91

#97 bhirbec closed 8 years ago
0
Group doesn't recover after internet connectivity issue

#96 bhirbec opened 8 years ago
4
panic: invalid memory address or nil pointer dereference

#95 jaredye opened 8 years ago
2
Run into "index out of range" when launch multiple concurrent consumers "go routine" in a single go process

#94 mrcold closed 8 years ago
1
Complementary fix of partition rebalnce issue(#62)

#93 caihua-yin closed 8 years ago
0
cg is still nil at this point

#92 davidreynolds closed 8 years ago
0
Error not handled with cg.instance.ReleasePartition()

#91 bhirbec closed 8 years ago
5
can i use this package if my offset is stored in kafka not zk ?

#90 WanliTian closed 8 years ago
2
does this client support batch consume?

#89 cch123 closed 7 years ago
4
Expose claim attempt maxRetries as Config.PartitionClaimRetries

#88 guildencrantz opened 8 years ago
0
Re-register when connection lost/timeout, fixes wvanbergen/kafka#80

#87 yejingx closed 8 years ago
2
when cg close, it should commit the offset before quit

#86 lovestorm88 opened 8 years ago
1
Start offset manager without previous offset, so the first offset seen will always be committable.

#85 wvanbergen closed 6 years ago
2
Add heavier locking to the FinalizePartition() function

#84 sparrc closed 7 years ago
5
Add a configuration setting to call to ResetOffsets on the cg.

#83 rrh closed 8 years ago
1