dashbitco/broadway_kafka

Issues

• Does not compile with Erlang 27 due to transitive dependencies

  #150 opened 2 months ago by mashton
  2

• Performance problems with shared_client option

  #148 opened 5 months ago by oliveigah
  1

• Implementing offset lag telemetry

  #145 opened 5 months ago by David-Klemenc
  5

• Fails to compile on otp 27

  #144 opened 5 months ago by GregorGrasselli
  9

• Updates on the release date of the next version?

  #143 opened 6 months ago by lfmatosm
  5

• Offsets accumulating in the producer ack state (take 2)

  #139 opened 8 months ago by danmarcab
  6

• Request for a new release

  #138 opened 8 months ago by oliveigah
  1

• Manual Partition Assignment

  #125 opened 9 months ago by David-Klemenc
  4

• Add support for reseting offsets to a specific timestamp

  #136 opened 9 months ago by danmarcab
  1

• Undesirable resource usage related to producer concurrency

  #132 opened a year ago by oliveigah
  8

• Allow to force consume the topic from the beginning or the end

  #129 opened a year ago by danmarcab
  0

• Feature: Add option to set the starting offset for new consumer

  #119 opened 2 years ago by MitchellJeppson
  6

• No rejoin after "payload connection down :shutdown, :tcp_closed}" deadlock on race between assigments_revoked call and handle DOWN message

  #112 opened 2 years ago by anoskov
  16

• Integration tests instructions and CI

  #61 opened 2 years ago by victorolinasc
  1

• Offsets accumulating in the producer ack state

  #100 opened 2 years ago by danmarcab
  5

• the table identifier does not refer to an existing ETS table

  #114 opened 2 years ago by yordis
  5

• Backoff strategy

  #124 opened 2 years ago by slashmili
  1

• drain_after_revoke failed due to killed process

  #117 opened 2 years ago by yordis
  3

• Support for pipelines using Registry / via tuple

  #57 opened 3 years ago by pbrooko
  2

• How to stop a Broadway Kafka pipeline?

  #86 opened 2 years ago by aravindanck
  3

• Producers stuck in :assignments_revoked causing endless group rebalancing

  #118 opened 2 years ago by Goose97
  24

• Deadlock on race between assigments_revoked call and handle DOWN message

  #116 opened 2 years ago by anoskov
  3

• When a new node joins, two consumers never go to a balancing state

  #92 opened 3 years ago by slashmili
  27

• Proposal: Use per partition internal buffer

  #98 opened 2 years ago by slashmili
  8

• Consumer Static Membership

  #109 opened 2 years ago by bkowalk
  9

• Cut release 0.3.6 ?

  #108 opened 2 years ago by robertkeizer
  2

• Support :query_api_versions brod option

  #106 opened 2 years ago by rewritten
  1

• Question: About a pipeline with a Batcher

  #99 opened 3 years ago by amacciola
  1

• [Docs] Documentation about handling failure

  #91 opened 3 years ago by yordis
  5

• Only one processors receives messages

  #89 opened 3 years ago by slashmili
  8

• Start offset for Broadway Kafka producer for a topic partition

  #87 opened 3 years ago by aravindanck
  3

• Shutdown Pipeline Gracefully when Topic is removed

  #88 opened 3 years ago by amacciola
  3

• Support for brod_gssapi and other custom brod sasl authenticators

  #82 opened 3 years ago by ramonpin
  7

• fetch_messages_from_kafka/3 Error: :unknown_server_error

  #83 opened 3 years ago by amacciola
  1

• Bump version to include bugfix

  #81 opened 3 years ago by samuelpordeus
  1

• Error after upgrading to v0.3.2

  #78 opened 3 years ago by juanperi
  7

• Latest Release (0.3.1) seems to always start from earliest offset

  #74 opened 3 years ago by amacciola
  7

• BroadwayKafka 0.3.1 is skipping the current offset

  #76 opened 3 years ago by alexandrexaviersm
  0

• Producer terminate

  #65 opened 3 years ago by FedericoPanS
  5

• Offset reset policy isn't applied for offsets out of range.

  #71 opened 3 years ago by jamespeterschinner
  7

• [Docs] Describe which Kafka metadata is store in Broadway.Message

  #67 opened 3 years ago by JVZELLER
  1

• Pipelines rebalancing errors

  #46 opened 3 years ago by amacciola
  7

• Specific client_id for the :brod client

  #59 opened 3 years ago by victorolinasc
  2

• Erlkaf as an optional kafka client

  #62 opened 3 years ago by escobera
  2

• Broadway suspend pipeline

  #56 opened 4 years ago by amacciola
  22

• Question about :receive_interval and topology.

  #58 opened 3 years ago by lud
  4

• Custom offset producer

  #55 opened 4 years ago by D4no0
  4

• Avro Schema Support

  #52 opened 4 years ago by amacciola
  1

• Major Assignments Issue In Master Branch

  #47 opened 4 years ago by amacciola
  9

• Drain After Revoke Error

  #43 opened 4 years ago by amacciola
  8