kafka4beam/brod issues and pull requests

#619 - feat: update Produce and Fetch APIs to support zstd compression

Pull Request - State: open - Opened by ShapovalovaIrina 4 days ago

#617 - Support Dynamic Topic Subscriptions Using Patterns in brod

Issue - State: open - Opened by jasontleo 23 days ago - 2 comments

#616 - how to config ssl truststore and other configuration?

Issue - State: closed - Opened by pigbayspy 29 days ago

#615 - Catch all exit exceptions when coordinator call member

Pull Request - State: closed - Opened by zmstone 2 months ago

#614 - Consistent "failed to flush commits before termination" error during consumer group shutdown

Issue - State: open - Opened by Tasyp 2 months ago - 2 comments

#613 - Added support for unknown_topic_cache_ttl option in brod_client

Pull Request - State: closed - Opened by mtvch 3 months ago - 1 comment

#611 - Exit group coordinator if member pid gone

Pull Request - State: closed - Opened by fmcgeough 3 months ago - 3 comments

#610 - Docs improvements

Pull Request - State: closed - Opened by mtvch 3 months ago - 1 comment

#609 - fix: support negative begin_offset in `brod_consumer`

Pull Request - State: closed - Opened by Tasyp 3 months ago - 4 comments

#608 - feat: add `get_coordinator` function in group subscriber v2

Pull Request - State: open - Opened by yastanotheruser 3 months ago - 4 comments

#607 - Process abnormal exit during termination when custom partitioning strategy is used

Issue - State: closed - Opened by Tasyp 3 months ago - 3 comments

#605 - Upgrade kafka_protocol from 4.1.9 to 4.1.10

Pull Request - State: closed - Opened by zmstone 4 months ago

#604 - Remove v prefix from version tags in GitHub URLs for doc links

Pull Request - State: closed - Opened by chulkilee 4 months ago

#603 - [Doc] "View Source" links on Hexdocs are broken

Issue - State: closed - Opened by chulkilee 4 months ago

#601 - fix: don't crash client if stopping an unknown consumer, stop `brod_consumer` processes when terminating `brod_group_subscriber_v2`

Pull Request - State: closed - Opened by thalesmg 4 months ago

#600 - refactor: delete brod_cli code

Pull Request - State: closed - Opened by zmstone 5 months ago

#598 - feat: add boolean flag 'share_leader_conn' in consumer config

Pull Request - State: closed - Opened by zmstone 5 months ago

#597 - chore: pin kafka_protocol 4.1.9 for OTP 27

Pull Request - State: closed - Opened by zmstone 5 months ago - 2 comments

#596 - Does not compile on Erlang 27 due to pinned kafka_protocol and transitive deps

Issue - State: closed - Opened by mashton 5 months ago

#595 - ci: use upload-artifacts v4 remove coveralls

Pull Request - State: closed - Opened by zmstone 5 months ago

#594 - Add additional auth plugins section

Pull Request - State: closed - Opened by starbelly 5 months ago - 1 comment

#593 - Fix typo in brod_consumer documentation

Pull Request - State: closed - Opened by tomkonidas 7 months ago - 1 comment

#592 - Sending tombstones with brod

Issue - State: closed - Opened by alexanderttalvarez 7 months ago - 1 comment

#591 - Expose ack_fun through the init_info

Pull Request - State: closed - Opened by indrekj 8 months ago - 2 comments

#590 - Fix type spec in brod_transaction

Pull Request - State: closed - Opened by indrekj 8 months ago - 2 comments

#589 - Fix folding over transactions

Pull Request - State: closed - Opened by indrekj 8 months ago - 3 comments

#588 - brod:fold doesn't work when there have been transactions

Issue - State: closed - Opened by indrekj 8 months ago - 2 comments

#587 - Guard against undefined pid in get partition worker

Pull Request - State: closed - Opened by zmstone 8 months ago

#585 - Add support for OTP 27

Pull Request - State: closed - Opened by kivra-pauoli 8 months ago - 6 comments

#584 - use official Kafka docker images for testing

Issue - State: closed - Opened by zmstone 8 months ago - 1 comment

#583 - Test with Kafka 3.6

Pull Request - State: closed - Opened by zmstone 8 months ago

#582 - Fix CI

Pull Request - State: closed - Opened by zmstone 8 months ago

#581 - Guard against undefined partition worker pid

Pull Request - State: closed - Opened by urmastalimaa 8 months ago - 6 comments

#580 - Proposal: Forward unhandled messages to optional subscriber handle_info callback

Pull Request - State: closed - Opened by urmastalimaa 9 months ago - 3 comments

#579 - Does it support jks file sert?

Issue - State: closed - Opened by Vkutovoy92 10 months ago - 3 comments

#578 - Fix coordinator process exiting due to heartbeat race

Pull Request - State: closed - Opened by laurglia 10 months ago - 3 comments

#577 - Low-latency consumer polling

Issue - State: closed - Opened by zidik 10 months ago - 5 comments

#576 - Authenticity is not established by certificate path validation", Reason: "Option {verify, verify_peer} and cacertfile/cacerts is missing

Issue - State: closed - Opened by Vkutovoy92 10 months ago - 2 comments

#575 - Remove unused macros (as detected by ELP)

Pull Request - State: closed - Opened by robertoaloi about 1 year ago

#574 - chore: upgrade to kafka_protocol from 4.1.3 to 4.1.5

Pull Request - State: closed - Opened by zmstone about 1 year ago

#573 - docs: fix readme

Pull Request - State: closed - Opened by zmstone about 1 year ago

#572 - Change supervisor3 info to debug logger level

Pull Request - State: closed - Opened by Qizot about 1 year ago

#571 - fix: type spec of v2 group consumer handle_message

Pull Request - State: closed - Opened by chsukivra about 1 year ago

#570 - Why constant UNKNOWN_TOPIC_CACHE_EXPIRE_SECONDS (module brod_client) hard set 120 seconds?

Issue - State: closed - Opened by dbegunkov about 1 year ago - 4 comments

#569 - Behavior `brod_auth_backend` is mentioned in the docs but does not exist in the code

Issue - State: closed - Opened by jesperes over 1 year ago - 1 comment

#568 - How to limit message batch size or ack in middle of handling message batch?

Issue - State: closed - Opened by mindreader over 1 year ago - 5 comments

#567 - Misleading handling of begin offset for Consumer groups

Issue - State: open - Opened by gdwoolbert3 over 1 year ago

#565 - bump kafka_protocol to 4.1.3

Pull Request - State: closed - Opened by dbegunkov over 1 year ago - 2 comments

#564 - Publish 3.16.8 to Hex.pm

Issue - State: closed - Opened by kivra-pauoli over 1 year ago - 1 comment

#562 - fix: Extracts coveralls from `plugins` list to `project_plugins`

Pull Request - State: closed - Opened by isaacsanders over 1 year ago - 2 comments

#561 - Brod supervisor3

Pull Request - State: closed - Opened by ieQu1 over 1 year ago

#560 - Please release a new version

Issue - State: closed - Opened by VitorTrin almost 2 years ago - 3 comments

#559 - chore: bump snappyer vsn to 1.2.9

Pull Request - State: closed - Opened by JimMoen almost 2 years ago - 1 comment

#558 - fix a very minor typo in the README

Pull Request - State: closed - Opened by jvantuyl almost 2 years ago

#557 - Is there support for fetch from follower?

Issue - State: open - Opened by tpitale almost 2 years ago

#556 - Copy supervisor3 from klarna/supervisor3 into brod

Pull Request - State: closed - Opened by gonzalobf almost 2 years ago - 2 comments

#555 - feat(group_subscriber_v2): add `get_wokers` function

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

#554 - broad_auth_backend behaviour is mentioned instead of kpro_auth_backend

Issue - State: closed - Opened by kevinkjt2000 about 2 years ago

#553 - Handle new opaque types in gen_server on OTP 25

Pull Request - State: closed - Opened by jesperes about 2 years ago - 1 comment

#552 - Dialyzer error in brod_cg_commits.erl on OTP 25

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

#549 - feature: support for transactions

Pull Request - State: closed - Opened by axs-mvd about 2 years ago - 11 comments

#548 - upgrade supervisor3 from 1.1.11 to 1.1.12

Pull Request - State: closed - Opened by JamieMaclean about 2 years ago

#547 - Remove snappyer from default dependency

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

#546 - [rfc] redesign the process management tree

Issue - State: open - Opened by zmstone about 2 years ago - 3 comments

#545 - chore: update kafka_protocol -> 4.1.2

Pull Request - State: closed - Opened by thalesmg about 2 years ago

#544 - chore: upgrade kafka_protocol -> 4.1.1

Pull Request - State: closed - Opened by thalesmg about 2 years ago - 1 comment

#543 - Add support for rack id

Pull Request - State: open - Opened by ditas about 2 years ago - 2 comments

#542 - How to disable startup log?

Issue - State: open - Opened by slashmili about 2 years ago - 3 comments

#541 - feat: add _safe flavor APIs for metadata and partition-count

Pull Request - State: closed - Opened by zmstone about 2 years ago - 3 comments

#540 - How to disable auto.commit

Issue - State: open - Opened by yordis about 2 years ago - 3 comments

#539 - Make user_data overridable

Pull Request - State: closed - Opened by dbalakavi over 2 years ago - 1 comment

#538 - brod_group_coordinator gets blocked by assignments_revoked and not able to accept commit_offsets

Issue - State: closed - Opened by slashmili over 2 years ago - 3 comments

#537 - PEM certificates as a value

Issue - State: closed - Opened by SerikDM over 2 years ago

#536 - How to properly disable the clients in tests

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

#535 - Use master as source_ref for ExDoc

Pull Request - State: closed - Opened by xxdavid over 2 years ago

#534 - Improve documentation

Pull Request - State: closed - Opened by xxdavid over 2 years ago - 11 comments

#533 - call get_partitions_count with checking allow_topic_auto_creation option

Pull Request - State: closed - Opened by dbegunkov over 2 years ago - 4 comments

#532 - Inconsistent subscriber behaviour

Issue - State: open - Opened by stephb9959 over 2 years ago - 1 comment

#531 - fix: commit record with offset = 0 should mean begin_offset = earliest

Pull Request - State: closed - Opened by zmstone over 2 years ago

#530 - ssl_closed error

Issue - State: open - Opened by zmstone over 2 years ago - 8 comments
Labels: enhancement, help wanted

#529 - Prettify MD/YAML files

Pull Request - State: closed - Opened by kianmeng over 2 years ago - 3 comments

#528 - feat: allow special offsets from consumer managed commits

Pull Request - State: closed - Opened by zmstone over 2 years ago

#527 - `brod_group_subscriber_v2` usage callback `CbModule:handle_message/2` instead of `CbModule:handle_message/4`

Issue - State: open - Opened by amarBitMan over 2 years ago - 1 comment
Labels: enhancement, help wanted

#526 - Group instance ID support (group.instance.id) (static membership)

Issue - State: open - Opened by anoskov over 2 years ago - 3 comments
Labels: enhancement, help wanted

#525 - Typo on doc where the key is timeout instead of timeout_ms

Pull Request - State: closed - Opened by robsonpeixoto over 2 years ago

#524 - KIP-429: Kafka Consumer Incremental Rebalance Protocol

Issue - State: open - Opened by robsonpeixoto over 2 years ago - 2 comments

#523 - Small improvements on README.md

Pull Request - State: closed - Opened by robsonpeixoto over 2 years ago

#522 - Fix the Elixir sample code and update all dependencies

Pull Request - State: closed - Opened by robsonpeixoto over 2 years ago

#521 - brod:fetch获取的kafka记录不完整

Issue - State: closed - Opened by tanwen321 over 2 years ago - 1 comment

#520 - No reconnect after "payload connection down :shutdown, :tcp_closed}"

Issue - State: closed - Opened by anoskov over 2 years ago - 9 comments

#519 - doc: show how to produce in a random partition using the random atom

Pull Request - State: closed - Opened by robsonpeixoto over 2 years ago

#518 - Update README.md

Pull Request - State: closed - Opened by mgibowski over 2 years ago

#517 - Unable to specify consumer offset to begin with first message

Issue - State: closed - Opened by SerikDM over 2 years ago - 7 comments

#516 - Enable SASL Handshake

Issue - State: closed - Opened by zavndw over 2 years ago - 7 comments

#515 - Fix `get_committed_offset` return specs

Pull Request - State: closed - Opened by SerikDM over 2 years ago - 2 comments

#514 - Update Publisher.md

Pull Request - State: closed - Opened by SerikDM over 2 years ago

#513 - Fix typo

Pull Request - State: closed - Opened by tomekowal over 2 years ago - 1 comment

#512 - WIP: add telemetry

Pull Request - State: open - Opened by spencerdcarlson over 2 years ago - 5 comments

#511 - feat: update kafka_protocol to 4.1.0

Pull Request - State: closed - Opened by kjellwinblad over 2 years ago

#510 - Brod producer connection terminates/fails without logging reason

Issue - State: open - Opened by kjellwinblad over 2 years ago

GitHub / kafka4beam/brod issues and pull requests