Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on May 2, 2025

• Update changes w/ 2.1.6 backport release

  dpkp

  committed
  827832a

  Copy full SHA for 827832a

Commits on May 1, 2025

• Patch Release 2.2.3

  dpkp

  committed
  2767d14

  Copy full SHA for 2767d14

• Ignore leading SECURITY_PROTOCOL:// in bootstrap_servers (#2608)

  dpkp

  authored
  cef0ea6

  Copy full SHA for cef0ea6

• Only create fetch requests for ready nodes (#2607)

  dpkp

  authored
  b6036f2

  Copy full SHA for b6036f2

Commits on Apr 30, 2025

• Bump version for development

  dpkp

  committed
  26fbd2e

  Copy full SHA for 26fbd2e

• Patch Release 2.2.2

  dpkp

  committed
  3d31c14

  Copy full SHA for 3d31c14

Commits on Apr 29, 2025

• Fix lint errors

  dpkp

  committed
  998efc2

  Copy full SHA for 998efc2

• Bump version for development

  dpkp

  committed
  cb2868f

  Copy full SHA for cb2868f

• Patch Release 2.2.1

  dpkp

  committed
  8c39733

  Copy full SHA for 8c39733

• Always try ApiVersionsRequest v0, even on broker disconnect (#2603)

  dpkp

  authored
  842f398

  Copy full SHA for 842f398

• Fix SubscriptionState AttributeError in KafkaConsumer (#2599)

  zcc0077

  authored
  c35c161

  Copy full SHA for c35c161

Commits on Apr 28, 2025

• Add transactional examples to docs

  dpkp

  committed
  284c8a7

  Copy full SHA for 284c8a7

• Bump version for development

  dpkp

  committed
  0f481e0

  Copy full SHA for 0f481e0

• Release 2.2.0

  dpkp

  committed
  603e10e

  Copy full SHA for 603e10e

Commits on Apr 27, 2025

• KIP-394: handle MEMBER_ID_REQUIRED error w/ second join group request (#2598)

  dpkp

  authored
  fb04626

  Copy full SHA for fb04626

• RecordAccumulator: Use helper method to get/set _tp_locks; get dq with lock in reenqueue()

  dpkp

  committed
  b1dae2e

  Copy full SHA for b1dae2e

• Expand KafkaProducer docstring w/ idempotent and transactional notes

  dpkp

  committed
  707913f

  Copy full SHA for 707913f

• Default retries -> infinite

  dpkp

  committed
  4f87a87

  Copy full SHA for 4f87a87

• KIP-91: KafkaProducer delivery_timeout_ms

  dpkp

  committed
  3b766e2

  Copy full SHA for 3b766e2

• MemoryRecords iterator; MemoryRecordsBuilder records() helper

  dpkp

  committed
  1f63514

  Copy full SHA for 1f63514

• DefaultRecordsBuilder.size_in_bytes classmethod

  dpkp

  committed
  3ee0419

  Copy full SHA for 3ee0419

• from __future__ import division for produce batch time calcs

  dpkp

  committed
  17ba216

  Copy full SHA for 17ba216

• KAFKA-5429 - Ignore produce response if batch was previously aborted

  dpkp

  committed
  186d480

  Copy full SHA for 186d480

• Do not include log_start_offset in producer RecordMetadata

  dpkp

  committed
  92037ce

  Copy full SHA for 92037ce

Commits on Apr 23, 2025

• Fix ElectionNotNeededError handling in admin client

  dpkp

  committed
  9188385

  Copy full SHA for 9188385

• KAFKA-6397: Consumer should not block setting positions of unavailable partitions (#2593)

  dpkp

  authored
  be9dd7c

  Copy full SHA for be9dd7c

• fixup exception message

  dpkp

  committed
  39aa421

  Copy full SHA for 39aa421

Commits on Apr 19, 2025

• Drop unused KafkaClient import from test_fetcher

  dpkp

  committed
  1b53598

  Copy full SHA for 1b53598

• KAFKA-5078 - defer fetch record exception if iterator has already moved across a valid record

  dpkp

  committed
  9300bcb

  Copy full SHA for 9300bcb

• KAFKA-5075 - Defer consumer fetcher exception if fetch position has already increased

  dpkp

  committed
  2513d55

  Copy full SHA for 2513d55

• KAFKA-4937: Batch offset fetches in the Consumer

  dpkp

  committed
  d166668

  Copy full SHA for d166668

• KAFKA-4547: Avoid resetting paused partitions to committed offsets

  dpkp

  committed
  2f262b9

  Copy full SHA for 2f262b9

Commits on Apr 17, 2025

• Fix client.wakeup() race from producer/sender close

  dpkp

  committed
  e92defe

  Copy full SHA for e92defe

• Avoid self refcount in log messages; test thread close on all pythons

  dpkp

  committed
  a2f8c58

  Copy full SHA for a2f8c58

• Prefix producer logs w/ client id and transactional id (#2591)

  dpkp

  authored
  99c08e6

  Copy full SHA for 99c08e6

Pagination

Previous

Next