bsm/sarama-cluster
Cluster extensions for Sarama, the Go client library for Apache Kafka 0.9 [DEPRECATED]
GoMIT
Issues
- 4
- 1
go get github.com/bsm/sarama-cluster报错
#306 opened by anranziruo - 1
Not able to Read the messages from the reset offset for the partition
#299 opened by continuum-dipanjan-mazumder - 1
What is the behavior of consumer in multiplex mode ?
#287 opened by dhbarman - 1
Create new tag for the latest commit
#240 opened by jessicaxiejw - 1
import with capital S creates issues
#243 opened by chadgrant - 2
consumer.Partitions not work?
#246 opened by adpoint - 1
Adding Topics() to Consumer
#248 opened by axbannaz - 2
ConsumerGroup with Azure EventHub
#252 opened by kaliazur - 6
Close partition after ResetOffset
#262 opened by e11it - 1
- 1
- 1
- 0
- 2
how can i consume form the commit offset?
#303 opened by Sallery-X - 0
- 3
go get error
#300 opened by kazaff - 1
- 2
- 19
Delivering disordered messages during shutdown(rebalance), causing message loss
#255 opened by longquanzheng - 4
- 2
Kafka repeated consumption
#293 opened by cafra - 1
DEPRECATED??
#292 opened by krucelee - 1
status of the library
#291 opened by matzew - 1
auto commit
#288 opened by matzew - 1
New updated sarama
#285 opened - 2
- 1
Consumer Partitions Mode is not working
#282 opened by dhbarman - 2
Closed connection to broker , how to reconnection
#280 opened by 24 - 7
New partitions are not seen by existing consumers
#242 opened by bataras - 2
Does sarama-cluster supports kafka 2.0?
#279 opened by zzmg - 1
#Support : Way to get batch messages and commit if the batch is successful
#274 opened by sanchitlohia-ovo - 1
- 2
- 1
Consumer Issue in decoding packet
#265 opened by harshitdx29 - 2
Mocking and Testing
#264 opened by jeroenrinzema - 1
initial messages in partitions are not delivered while sarama-cluster client was offline
#263 opened by notmaxx - 1
Upon closed dead subscription, Resubscribe
#261 opened by steve-gray - 1
- 3
Seeing lots of consumer errors with Sarama 1.17.0
#259 opened by jpiper - 1
- 2
Question: what's the plan, if any, for sarama.v2?
#251 opened by davecb - 3
how to add a topic dynamic
#237 opened by jiangxl2018 - 1
kafka: Failed to deliver 1 messages
#250 opened by adpoint - 1
Using ResetPartitionOffset after a rebalancing
#249 opened by asdine - 0
failed building example with vgo
#239 opened by wxart - 1
- 1
question for ConsumePartition
#244 opened by adpoint - 1
offset for many partitions
#245 opened by adpoint - 1
about the version of sarama
#238 opened by kuaikuai