8000 Tags · flysen/brod · GitHub
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

Tags: flysen/brod

Tags

3.7.7

Toggle 3.7.7's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Merge pull request kafka4beam#314 from klarna/fix-badrecord-race-for-…

…group-subscriber

Fix badrecord race when messages delivered after unsubscribe

3.7.6

Toggle 3.7.6's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Merge pull request kafka4beam#311 from klarna/fix-msg-input-type-spec

Fix msg_input type spec

3.7.5

Toggle 3.7.5's commit message
Bump kafka_protocol version to 2.2.7 (kafka4beam#309)

3.7.4

Toggle 3.7.4's commit message
Call erlang:function_exported/3 instead of module_info

3.7.3

Toggle 3.7.3's commit message
Bump to kafka_protocol 2.2.4

3.7.2

Toggle 3.7.2's commit message
On initial subscribe, the last_offset should be the acked_offset. (ka…

…fka4beam#299)

* Subscribes to partition when LastOffset is undef
* Adds a test for topic subscriber start offset passed in via init

3.7.1

Toggle 3.7.1's commit message
Simplify user_data in group protocol

3.7.0

Toggle 3.7.0's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Merge pull request kafka4beam#287 from klarna/do-not-restart-consumer…

…-on-leader-error

Reset connection instead of restart on leader error

3.6.2

Toggle 3.6.2's commit message
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.

3.6.1

Toggle 3.6.1's commit message

Verified

This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
Merge pull request kafka4beam#279 from klarna/make-produce-api-vsn-co…

…nfigurable
0