Ecosyste.ms: Issues

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

GitHub / dashbitco/broadway_kafka issues and pull requests

#150 - Does not compile with Erlang 27 due to transitive dependencies

Issue - State: closed - Opened by mashton 2 months ago - 2 comments

#149 - chore: add shared client performance disclaimer

Pull Request - State: closed - Opened by oliveigah 4 months ago - 1 comment

#148 - Performance problems with shared_client option

Issue - State: open - Opened by oliveigah 4 months ago - 1 comment

#147 - Add kafka lag query

Pull Request - State: closed - Opened by GregorGrasselli 4 months ago - 6 comments

#146 - maint: update brod dep to 4.0

Pull Request - State: closed - Opened by deepfryed 4 months ago - 6 comments

#145 - Implementing offset lag telemetry

Issue - State: closed - Opened by David-Klemenc 5 months ago - 5 comments

#144 - Fails to compile on otp 27

Issue - State: closed - Opened by GregorGrasselli 5 months ago - 9 comments

#143 - Updates on the release date of the next version?

Issue - State: closed - Opened by lfmatosm 5 months ago - 5 comments

#142 - CI Workfow Fixes

Pull Request - State: closed - Opened by Stratus3D 7 months ago - 2 comments

#141 - Fix errors caught by Dialyzer

Pull Request - State: closed - Opened by Stratus3D 7 months ago - 2 comments

#140 - Support for IPv6

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

#139 - Offsets accumulating in the producer ack state (take 2)

Issue - State: open - Opened by danmarcab 7 months ago - 6 comments

#138 - Request for a new release

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

#137 - Add support for timestamp offset_reset_policy

Pull Request - State: closed - Opened by danmarcab 9 months ago - 1 comment

#136 - Add support for reseting offsets to a specific timestamp

Issue - State: closed - Opened by danmarcab 9 months ago - 1 comment

#135 - `brod` supports sasl credentials from file

Pull Request - State: closed - Opened by rewritten 11 months ago - 4 comments

#134 - docs: Update dependency in readme to 0.4.1

Pull Request - State: closed - Opened by eulixir 12 months ago - 1 comment

#133 - feat: implement shared client

Pull Request - State: closed - Opened by oliveigah about 1 year ago - 5 comments

#132 - Undesirable resource usage related to producer concurrency

Issue - State: closed - Opened by oliveigah about 1 year ago - 8 comments

#131 - Adapt tests to OTP26

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

#130 - feat: add :begin_offset option

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

#128 - set GitHub Action runner to latest

Pull Request - State: closed - Opened by slashmili over 1 year ago - 3 comments

#127 - run integration test on ci

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

#126 - Improve Buffer Management and Message Processing in BroadwayKafka.Producer

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

#125 - Manual Partition Assignment

Issue - State: closed - Opened by David-Klemenc over 1 year ago - 4 comments

#124 - Backoff strategy

Issue - State: open - Opened by slashmili over 1 year ago - 1 comment
Labels: contributions welcome

#123 - fix: check draining state from ets

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

#122 - fix integration tests

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

#121 - disable offset_commit_on_ack during revoke assignment call

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

#120 - fix: allow begin_offset brod option

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

#119 - Feature: Add option to set the starting offset for new consumer

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

#118 - Producers stuck in :assignments_revoked causing endless group rebalancing

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

#117 - drain_after_revoke failed due to killed process

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

#116 - Deadlock on race between assigments_revoked call and handle DOWN message

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

#115 - fix: no case clause maching error timeout

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

#114 - the table identifier does not refer to an existing ETS table

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

#113 - Add :request_timeout option to BrodClient

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

#111 - send telemetry when assignments_revoked is executed

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

#110 - Use Ring style as buffer

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

#109 - Consumer Static Membership

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

#108 - Cut release 0.3.6 ?

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

#107 - feat: query_api_versions support for broad client

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

#106 - Support :query_api_versions brod option

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

#105 - Wait for create topics in integration tests

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

#104 - Bumping brod and calling :brod_group_coordinator.stop

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

#103 - Allow blocking the queue and retrying messages from the failed message's offset

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

#102 - store messages for each partition in different queue

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

#101 - Fix yaml in integration test

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

#100 - Offsets accumulating in the producer ack state

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

#99 - Question: About a pipeline with a Batcher

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

#98 - Proposal: Use per partition internal buffer

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

#97 - Don't hand new events while is in assignment_revoked state

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

#96 - Emit warning when rebalancing take time

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

#95 - allow rebalance_timeout_seconds option to be passed to bord

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

#94 - Improvement in integration test

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

#93 - Keep draining flag after assignment is revoked in ETS table

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

#92 - When a new node joins, two consumers never go to a balancing state

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

#91 - [Docs] Documentation about handling failure

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

#90 - Do not send more than max_demand to a single processor

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

#89 - Only one processors receives messages

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

#88 - Shutdown Pipeline Gracefully when Topic is removed

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

#87 - Start offset for Broadway Kafka producer for a topic partition

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

#86 - How to stop a Broadway Kafka pipeline?

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

#85 - Support for custom brod sasl authenticators

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

#84 - fix(docs): keyword list example is invalid elixir

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

#83 - fetch_messages_from_kafka/3 Error: :unknown_server_error

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

#82 - Support for brod_gssapi and other custom brod sasl authenticators

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

#81 - Bump version to include bugfix

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

#80 - pass SSL configurations when validating offset

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

#79 - relax error tuple when trying to resolve offset

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

#78 - Error after upgrading to v0.3.2

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

#77 - Fix integration tests

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

#76 - BroadwayKafka 0.3.1 is skipping the current offset

Issue - State: closed - Opened by alexandrexaviersm almost 3 years ago

#75 - Use reset_policy only when offset is undefined or out_of_range

Pull Request - State: closed - Opened by alexandrexaviersm almost 3 years ago - 6 comments

#74 - Latest Release (0.3.1) seems to always start from earliest offset

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

#73 - Add heartbeat_rate_seconds option to group_config

Pull Request - State: closed - Opened by danielkv7 almost 3 years ago - 4 comments

#72 - Update resolve offset function to handle :offset_out_of_range errors

Pull Request - State: closed - Opened by jamespeterschinner almost 3 years ago - 1 comment

#71 - Offset reset policy isn't applied for offsets out of range.

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

#70 - docs: fix typo

Pull Request - State: closed - Opened by polvalente about 3 years ago - 1 comment

#69 - Callbacks on rebalancing

Pull Request - State: closed - Opened by marinanekrassova about 3 years ago

#68 - docs: add message metadata information to docs

Pull Request - State: closed - Opened by JVZELLER about 3 years ago - 1 comment

#67 - [Docs] Describe which Kafka metadata is store in Broadway.Message

Issue - State: closed - Opened by JVZELLER about 3 years ago - 1 comment

#66 - Fix brod disconnection on terminate

Pull Request - State: closed - Opened by FedericoPanS about 3 years ago - 14 comments

#65 - Producer terminate

Issue - State: closed - Opened by FedericoPanS about 3 years ago - 5 comments

#64 - feat: allow sasl value to be `:undefined`

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

#63 - Fix typos

Pull Request - State: closed - Opened by kianmeng about 3 years ago - 1 comment

#62 - Erlkaf as an optional kafka client

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

#61 - Integration tests instructions and CI

Issue - State: closed - Opened by victorolinasc over 3 years ago - 1 comment
Labels: contributions welcome

#60 - Add client_id option to client_config

Pull Request - State: closed - Opened by victorolinasc over 3 years ago - 6 comments

#59 - Specific client_id for the :brod client

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

#58 - Question about :receive_interval and topology.

Issue - State: closed - Opened by lud over 3 years ago - 4 comments

#57 - Support for pipelines using Registry / via tuple

Issue - State: open - Opened by pbrooko over 3 years ago - 2 comments
Labels: contributions welcome

#56 - Broadway suspend pipeline

Issue - State: closed - Opened by amacciola over 3 years ago - 22 comments

#55 - Custom offset producer

Issue - State: closed - Opened by D4no0 over 3 years ago - 4 comments

#54 - Use Broadway public API instead of private on change_topics

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

#53 - Fix typo

Pull Request - State: closed - Opened by tschmidleithner over 3 years ago - 1 comment

#52 - Avro Schema Support

Issue - State: closed - Opened by amacciola over 3 years ago - 1 comment

#51 - Support for max_wait_time in fetch config

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