Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / bsm/sarama-cluster issues and pull requests

#308 - 修改consumer提交的时间间隔

Pull Request - State: open - Opened by CHneger almost 5 years ago

#307 - c.client.config.Config.Consumer.Offsets.CommitInterval undefined

Issue - State: closed - Opened by liusha0917 almost 5 years ago - 4 comments

#306 - go get github.com/bsm/sarama-cluster报错

Issue - State: closed - Opened by anranziruo almost 5 years ago - 1 comment

#305 - sarama config.go removed config.Consumer.Offsets.CommitInterval in config.go

Issue - State: closed - Opened by cage1993 almost 5 years ago - 1 comment

#304 - Offsets.CommitInterval has change to Offsets.AutoCommit.Interval

Issue - State: closed - Opened by kira3007 almost 5 years ago - 1 comment

#303 - how can i consume form the commit offset?

Issue - State: closed - Opened by Sallery-X almost 5 years ago - 2 comments

#302 - how

Issue - State: closed - Opened by Sallery-X almost 5 years ago

#301 - how can i set auto.offset.reset=none in sarama-cluster ?

Issue - State: closed - Opened by Sallery-X almost 5 years ago

#300 - go get error

Issue - State: closed - Opened by kazaff almost 5 years ago - 3 comments

#298 - rebalance when reassign partition

Pull Request - State: closed - Opened by clhongooo about 5 years ago - 1 comment

#297 - How to get Notification() - rebalance notification in sarama lib

Issue - State: closed - Opened by lingzhang000 over 5 years ago - 1 comment

#296 - Receiving protobuf data triggers a kafka unknown error

Issue - State: closed - Opened by hookover over 5 years ago - 2 comments

#295 - Copy Notification on error to prevent data race (#236)

Pull Request - State: closed - Opened by pmalekn over 5 years ago

#294 - commitOffset does not work properly in partition mode

Issue - State: closed - Opened by carl-leopard over 5 years ago - 4 comments

#293 - Kafka repeated consumption

Issue - State: closed - Opened by cafra over 5 years ago - 2 comments

#292 - DEPRECATED??

Issue - State: closed - Opened by krucelee over 5 years ago - 1 comment

#291 - status of the library

Issue - State: closed - Opened by matzew over 5 years ago - 1 comment

#290 - Fix typo in godoc

Pull Request - State: closed - Opened by nak3 over 5 years ago

#289 - Fix function comments based on best practices from Effective Go

Pull Request - State: closed - Opened by CodeLingoTeam over 5 years ago

#288 - auto commit

Issue - State: closed - Opened by matzew over 5 years ago - 1 comment

#287 - What is the behavior of consumer in multiplex mode ?

Issue - State: closed - Opened by dhbarman almost 6 years ago - 1 comment

#286 - Consumer per topic vs multiple topics per consumer

Issue - State: closed - Opened by saraweinberg almost 6 years ago - 1 comment

#285 - New updated sarama

Issue - State: closed - Opened by ghost almost 6 years ago - 1 comment

#284 - update sarama constants

Pull Request - State: closed - Opened by jakekeeys almost 6 years ago - 4 comments

#283 - how to limit number of partitions assigned to consumer

Issue - State: closed - Opened by nitin302 almost 6 years ago - 2 comments

#282 - Consumer Partitions Mode is not working

Issue - State: closed - Opened by dhbarman almost 6 years ago - 1 comment

#281 - fix dying consumer deadlock during rebalance

Pull Request - State: closed - Opened by angrz almost 6 years ago - 1 comment

#280 - Closed connection to broker , how to reconnection

Issue - State: closed - Opened by 24 about 6 years ago - 2 comments

#279 - Does sarama-cluster supports kafka 2.0?

Issue - State: closed - Opened by zzmg about 6 years ago - 2 comments

#278 - Expose underlying consumer errors

Pull Request - State: closed - Opened by pkedy about 6 years ago

#277 - Update README.md

Pull Request - State: closed - Opened by php-cpm about 6 years ago

#276 - README should be updated

Pull Request - State: closed - Opened by yeluyang about 6 years ago - 2 comments

#275 - Use GroupProtocol chosen by CG Coordinator

Pull Request - State: closed - Opened by stevevls about 6 years ago - 1 comment

#273 - Add missing parentheses

Pull Request - State: closed - Opened by ggirtsou about 6 years ago - 1 comment

#272 - Fix build

Pull Request - State: closed - Opened by seventy-two about 6 years ago - 1 comment

#271 - Fixed race condition when changing a notification after sending

Pull Request - State: closed - Opened by blockchainian about 6 years ago - 2 comments

#270 - Consumer offset resetting after partition leader change

Issue - State: closed - Opened by muirdm about 6 years ago - 1 comment

#269 - How to start a consumer group consuming from the latest committed offsets?

Issue - State: closed - Opened by vdobler about 6 years ago - 2 comments

#268 - Add custom offsets feature

Pull Request - State: closed - Opened by gqcn about 6 years ago - 1 comment

#267 - made error handling in PartitionModeConsumer conform to docs

Pull Request - State: closed - Opened by stevevls about 6 years ago

#266 - Update config.go to correct typos

Pull Request - State: closed - Opened by jgeiger about 6 years ago

#265 - Consumer Issue in decoding packet

Issue - State: closed - Opened by harshitdx29 about 6 years ago - 1 comment

#264 - Mocking and Testing

Issue - State: closed - Opened by jeroenrinzema about 6 years ago - 2 comments

#262 - Close partition after ResetOffset

Issue - State: closed - Opened by e11it about 6 years ago - 6 comments

#261 - Upon closed dead subscription, Resubscribe

Issue - State: closed - Opened by steve-gray about 6 years ago - 1 comment

#260 - Understanding rebalance and parallel consumers payload processing

Issue - State: closed - Opened by misterion over 6 years ago - 1 comment

#259 - Seeing lots of consumer errors with Sarama 1.17.0

Issue - State: closed - Opened by jpiper over 6 years ago - 3 comments

#258 - Fix PartitionConsumer race condition on Close.

Pull Request - State: closed - Opened by georgeteo over 6 years ago - 1 comment

#257 - Feature/v3

Pull Request - State: closed - Opened by dim over 6 years ago

#256 - V3

Pull Request - State: closed - Opened by dim over 6 years ago

#254 - A DATA RACE about Notification in cluster.balancer.go

Issue - State: closed - Opened by happyroc over 6 years ago - 1 comment

#253 - Added InitialOffsetMetadata to PartitionConsumer interface

Pull Request - State: closed - Opened by msample over 6 years ago - 1 comment

#252 - ConsumerGroup with Azure EventHub

Issue - State: closed - Opened by kaliazur over 6 years ago - 2 comments

#251 - Question: what's the plan, if any, for sarama.v2?

Issue - State: closed - Opened by davecb over 6 years ago - 2 comments

#250 - kafka: Failed to deliver 1 messages

Issue - State: closed - Opened by adpoint over 6 years ago - 1 comment

#249 - Using ResetPartitionOffset after a rebalancing

Issue - State: closed - Opened by asdine over 6 years ago - 1 comment

#248 - Adding Topics() to Consumer

Issue - State: closed - Opened by axbannaz over 6 years ago - 1 comment

#247 - Consumer and Azure Event Hub Kafka preview, can't connect

Issue - State: closed - Opened by AlexandreRzc over 6 years ago - 1 comment

#246 - consumer.Partitions not work?

Issue - State: closed - Opened by adpoint over 6 years ago - 2 comments

#245 - offset for many partitions

Issue - State: closed - Opened by adpoint over 6 years ago - 1 comment

#244 - question for ConsumePartition

Issue - State: closed - Opened by adpoint over 6 years ago - 1 comment

#243 - import with capital S creates issues

Issue - State: closed - Opened by chadgrant over 6 years ago - 1 comment

#242 - New partitions are not seen by existing consumers

Issue - State: closed - Opened by bataras over 6 years ago - 7 comments

#241 - Copy Notification on error to prevent data race (#236)

Pull Request - State: closed - Opened by sronderos-atlassian over 6 years ago - 1 comment

#240 - Create new tag for the latest commit

Issue - State: closed - Opened by jessicaxiejw over 6 years ago - 1 comment

#239 - failed building example with vgo

Issue - State: closed - Opened by wxart over 6 years ago

#238 - about the version of sarama

Issue - State: closed - Opened by kuaikuai over 6 years ago - 1 comment

#237 - how to add a topic dynamic

Issue - State: closed - Opened by jiangxl2018 over 6 years ago - 3 comments

#235 - Adding partitions to a topic during runtime does not trigger a rebalance

Issue - State: closed - Opened by toefel18 over 6 years ago - 8 comments

#234 - V3

Pull Request - State: closed - Opened by dim over 6 years ago - 4 comments

#233 - how can i consume msg from specified offset

Issue - State: closed - Opened by lpxxn over 6 years ago - 2 comments

#232 - implement my own partition.assignment.strategy

Issue - State: closed - Opened by jchenz over 6 years ago - 4 comments

#220 - Connect to new topics

Issue - State: closed - Opened by veger almost 7 years ago - 8 comments

#212 - Rolling reboot of kafka nodes causing rebalance errors

Issue - State: closed - Opened by jerrygb almost 7 years ago - 4 comments

#202 - Question - creating config and client from existing sarama config and client

Issue - State: closed - Opened by varun06 almost 7 years ago - 3 comments

#200 - Support Kafka 1.0

Pull Request - State: closed - Opened by dim almost 7 years ago

#188 - Fix race, added clarifying comment to CommitOffsets

Pull Request - State: closed - Opened by dim about 7 years ago - 1 comment

#184 - Make Close thread-safe

Pull Request - State: closed - Opened by dim about 7 years ago - 4 comments

#182 - Allow to re-use clients

Pull Request - State: closed - Opened by dim about 7 years ago - 2 comments

#179 - Add the ability to rewind offsets based on time

Pull Request - State: closed - Opened by aravindvs about 7 years ago - 11 comments

#170 - Incremental consumer subscriptions to topics

Issue - State: closed - Opened by agforte about 7 years ago - 17 comments

#166 - sarama.MockBroker error with sarama-cluster

Issue - State: closed - Opened by jvrmaia about 7 years ago - 9 comments

#165 - Consumer can not set arbitrary offset

Issue - State: closed - Opened by warreneblackwell about 7 years ago - 2 comments

#164 - Automagically commited offset in case of a crash

Issue - State: closed - Opened by niels-s about 7 years ago - 9 comments

#155 - notify consumers of rebalance in progress #98

Pull Request - State: closed - Opened by vavrusa about 7 years ago - 5 comments

#130 - Make message channel buffered

Pull Request - State: closed - Opened by Mirey-zz over 7 years ago - 4 comments

#127 - Consumer: lz4.Read: invalid header checksum

Issue - State: closed - Opened by Typositoire over 7 years ago - 3 comments

#126 - #Partitions change not reflected on consumer client

Issue - State: closed - Opened by vramakrishnan over 7 years ago - 6 comments

#118 - Error: Offset's topic has not yet been created

Issue - State: closed - Opened by mengzhuo over 7 years ago - 6 comments

#76 - How to disable auto commit?

Issue - State: closed - Opened by aklinkert about 8 years ago - 14 comments

#48 - When I add partitions to a topic, consumer does not trigger a rebalance.

Issue - State: closed - Opened by lrita over 8 years ago - 8 comments

#29 - Error when staring more consumers than patitions

Issue - State: closed - Opened by riaan53 over 8 years ago - 6 comments