dashbitco/broadway_kafka

Issues

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

  #139 opened 2 months ago by danmarcab
  6

• Request for a new release

  #138 opened 2 months ago by oliveigah
  1

• Manual Partition Assignment

  #125 opened 3 months ago by David-Klemenc
  4

• Add support for reseting offsets to a specific timestamp

  #136 opened 3 months ago by danmarcab
  1

• Undesirable resource usage related to producer concurrency

  #132 opened 8 months ago by oliveigah
  8

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

  #129 opened 10 months 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 a year ago by anoskov
  16

• Integration tests instructions and CI

  #61 opened a year ago by victorolinasc
  1

• Offsets accumulating in the producer ack state

  #100 opened a year ago by danmarcab
  5

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

  #114 opened a year ago by yordis
  5

• Backoff strategy

  #124 opened a year ago by slashmili
  1

• drain_after_revoke failed due to killed process

  #117 opened a year 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 a year ago by aravindanck
  3

• Producers stuck in :assignments_revoked causing endless group rebalancing

  #118 opened a year 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 2 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 2 years ago by amacciola
  1

• [Docs] Documentation about handling failure

  #91 opened 2 years ago by yordis
  5

• Only one processors receives messages

  #89 opened 2 years ago by slashmili
  8

• Start offset for Broadway Kafka producer for a topic partition

  #87 opened 2 years ago by aravindanck
  3

• Shutdown Pipeline Gracefully when Topic is removed

  #88 opened 2 years ago by amacciola
  3

• Support for brod_gssapi and other custom brod sasl authenticators

  #82 opened 2 years ago by ramonpin
  7

• fetch_messages_from_kafka/3 Error: :unknown_server_error

  #83 opened 2 years ago by amacciola
  1

• Bump version to include bugfix

  #81 opened 2 years ago by samuelpordeus
  1

• Error after upgrading to v0.3.2

  #78 opened 2 years ago by juanperi
  7

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

  #74 opened 2 years ago by amacciola
  7

• BroadwayKafka 0.3.1 is skipping the current offset

  #76 opened 2 years ago by alexandrexaviersm
  0

• Producer terminate

  #65 opened 2 years ago by FedericoPanS
  5

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

  #71 opened 2 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 3 years ago by amacciola
  22

• Question about :receive_interval and topology.

  #58 opened 3 years ago by lud
  4

• Custom offset producer

  #55 opened 3 years ago by D4no0
  4

• Avro Schema Support

  #52 opened 3 years ago by amacciola
  1

• Major Assignments Issue In Master Branch

  #47 opened 3 years ago by amacciola
  9

• Drain After Revoke Error

  #43 opened 3 years ago by amacciola
  8

• exactly once delivery (EOD) in stream processing

  #39 opened 3 years ago by matreyes
  3

• Move INFO level logging to DEBUG level

  #37 opened 3 years ago by amacciola
  5

• Multiple processors when having a single partition/producer

  #42 opened 4 years ago by juanperi
  3

• Proper way to stop/pause a Pipeline && start again using same consumer_group_id

  #38 opened 4 years ago by amacciola
  15

• [Question] Obtain metadata in handle_message

  #36 opened 4 years ago by sweco-semtne
  2