All pull requests

Pull requests

• Add headers_encoding to decode AMQP-encoded header values

  #286·emanueldejanu opened Sep 29, 2026·

  ·
  1

• Update Kafka client to 4.3.1

  #285·emanueldejanu opened Sep 29, 2026·

  ·
  2

• [Backport 11.x #282][Test] create bigger payloads to pass Kafka batch size

  #283·andsel opened Sep 17, 2026Contributor·

  ·
  2

  

• Add message_headers_field option to kafka output

  #278·mbelaloui opened Sep 1, 2026·

  ·
  1

  4

• Add commit_after_pq_fsync: commit Kafka offsets only after the persistent queue fsyncs

  #272·LolloneS opened Jul 31, 2026·2 tasks done·

  ·

• Add share group consumer

  #252·orangecola opened Apr 18, 2026·

  ·
  1

  31

• change to new mirror, dry kafka version, better curl flags

  #198·jsvd opened Jun 30, 2025Member·

  ·
  2

• Add on_shutdown with options abandon and release

  #197·yaauie opened Jun 26, 2025Contributor·

  ·

• Add missing oauth config (#180)

  status:needs-triage
  #181·hgword opened Sep 12, 2024·

  ·
  1

• Add schema_registry_api_key to kafka input

  status:needs-triage
  #179·vineethpp opened Aug 23, 2024·

  ·
  3

• docs: clarify limitations of header decoration

  status:approved
  #173·yaauie opened Jul 10, 2024Contributor·

  ·
  4

• fix schema registry proxy handling

  status:work-in-progress
  #170·jsvd opened Jun 6, 2024Member·

  ·
  1

  

• Add producer config to enable producer idempotence

  status:needs-triage
  #152·hellopeera opened Oct 20, 2023·

  ·

• Added support for the custom client and login callback handler for the kafka-output

  status:needs-triage
  #102·imsatasia opened Jul 30, 2021·

  ·
  1

• Refactor: block less while queue-ing output records

  status:work-in-progress
  #68·kares opened Jan 27, 2021Contributor·

  ·
  

• Added conf to choose if appending thread number to client_id or not

  status:needs-triage
  #55·arman1371 opened Aug 28, 2020·

  ·
  1

  1