Tags: flysen/brod
Tags
Merge pull request kafka4beam#314 from klarna/fix-badrecord-race-for-… …group-subscriber Fix badrecord race when messages delivered after unsubscribe
Merge pull request kafka4beam#311 from klarna/fix-msg-input-type-spec Fix msg_input type spec
Merge pull request kafka4beam#287 from klarna/do-not-restart-consumer… …-on-leader-error Reset connection instead of restart on leader error
Allows a topic subscriber to start reading a partition from offset 0 (k… …afka4beam#282) by allowing the client to pass in an offset of -1. This seems like the only reasonable way to maintain the old API while allowing the full breadth of starting offset values. Gross as it is, this shouldn't break dialyzer as kpro:offset seems to be a signed int.
Merge pull request kafka4beam#279 from klarna/make-produce-api-vsn-co… …nfigurable
PreviousNext