bsm/sarama-cluster
Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
GoMIT
Issues
- 8
Connect to new topics
#220 opened by veger - 4
Consumer.Close is stuck if process is terminate before Consumer.subscribe can be finished
#228 opened by wingdog - 4
implement my own partition.assignment.strategy
#232 opened by jchenz - 6
Data Race when rebalance notifications are enabled and a rebalance error occurs
#236 opened by sronderos-atlassian - 9
Automagically commited offset in case of a crash
#164 opened by niels-s - 2
Consumer can not set arbitrary offset
#165 opened by warreneblackwell - 4
what should we do if we encounter error while consuming in Errors Channel (EOF)
#171 opened by chandradeepak - 8
- 3
- 9
sarama.MockBroker error with sarama-cluster
#166 opened by jvrmaia - 17
Incremental consumer subscriptions to topics
#170 opened by agforte - 4
- 1
Consumer stopped receiving messages after getting network errors from Consumer.Errors() channel
#227 opened by wingdog - 2
how can i consume msg from specified offset
#233 opened by lpxxn - 4
- 1
Documentation clarification
#224 opened by petitout - 1
how can i get the uncommited
#225 opened by wshelly - 2
JSON RawMesage - Not able to consume the message
#229 opened by surajkb74 - 1
How can i consume msg from a specified offset
#230 opened by 2534999 - 1
how to create consumer
#226 opened by kazaff - 2
Consumer-based offset tracking?
#210 opened by opb - 3
"Version 1" member assignments causing problems
#211 opened by thomaslee - 2
- 7
Release new version of sarama-cluster
#223 opened by georgeteo - 3
Undefined "Full" trait for config metadata
#217 opened by norendren - 2
ResetPartitionOffset throws NPE
#214 opened by georgeteo - 1
compile fail
#213 opened by flybeyond - 3
Expose MarkOffset on PartitionConsumer
#203 opened by gaffneyc - 3
Question - Why Partitionconsumer interface different from sarama PartitionConsumer interface?
#205 opened by varun06 - 3
Does sarama-cluster _actually_ supports Kafka 0.11?
#206 opened by matbhz - 11
consumer keeps shutting down itself because it's request offset is always greater than server's offset
#204 opened by imjustfly - 2
Make Close drain partitions, and add AsyncClose
#193 opened by ooesili - 7
- 1
- 0
Travis tests are broken with incorrect mirror
#199 opened by jerrygb - 1
Did not rebalance for Apache Kafka 1.0.0
#194 opened by canyou2014 - 1
- 1
- 1
- 1
Can I use sarama-cluster like this?
#191 opened by liaojianqi - 2
Version lock in 2.1.9 for sarama
#190 opened by frankdejonge - 1
- 3
Race detector flags race in CommitOffsets
#185 opened by aaronlehmann - 1
v2.1.9 build causes some errors
#187 opened by qazqwe1596357 - 5
consumer group Owner
#181 opened by liaojianqi - 1
Migrating offsets from zookeeper to kakfa
#175 opened by sagard - 1
Authentication/Authorization in Kafka
#178 opened by nbcohen - 4
Restarting at offset
#177 opened by nbcohen - 3
Deadlock when sarama commit an out of range offset
#167 opened by aravindvs - 1
Unnecessary wait before fetching offsets
#161 opened by vavrusa