Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 29, 2025

• KIP-207: Add ListOffsetsRequest v5 / handle OffsetNotAvailableError (#2657)

  dpkp

  authored
  2abf2cd

  Copy full SHA for 2abf2cd

Commits on Jun 27, 2025

• KIP-430: Return Authorized Operations in Describe Responses (#2656)

  dpkp

  authored
  93bcdde

  Copy full SHA for 93bcdde

Commits on Jun 26, 2025

• python2 fixups (#2655)

  dpkp

  authored
  8fb3f96

  Copy full SHA for 8fb3f96

Commits on Jun 24, 2025

• Remove old/unused kafka.protocol.pickle (#2653)

  dpkp

  authored
  223c320

  Copy full SHA for 223c320

• Switch protocol code to getattr/setattr from __dict__ (#2654)

  dpkp

  authored
  8c6c9da

  Copy full SHA for 8c6c9da

Commits on Jun 23, 2025

• cli fixups: producer stdin/eof support; consumer unused e var

  dpkp

  committed
  c8d6cda

  Copy full SHA for c8d6cda

• cli fixups: producer py2 compat; consumer no stacktrace on KafkaError

  dpkp

  committed
  46319a3

  Copy full SHA for 46319a3

• KIP-345 Consumer group static membership (#2625)

  dpkp

  authored
  8d75d9a

  Copy full SHA for 8d75d9a

• Fix coordinator lock contention during close() (#2652)

  dpkp

  authored
  c95dad9

  Copy full SHA for c95dad9

• Drop unused imports (#2651)

  dpkp

  authored
  7b565ae

  Copy full SHA for 7b565ae

• python -m cli interfaces for kafka.admin, kafka.consumer, kafka.producer (#2650)

  dpkp

  authored
  6f6a696

  Copy full SHA for 6f6a696

• Add send_request() and send_requests() to KafkaAdminClient (#2649)

  dpkp

  authored
  179c8ed

  Copy full SHA for 179c8ed

Commits on Jun 20, 2025

• Patch Release 2.2.13

  dpkp

  committed
  f6eb0b4

  Copy full SHA for f6eb0b4

Commits on Jun 19, 2025

• Fixup import style in example.py

  dpkp

  committed
  0735a7c

  Copy full SHA for 0735a7c

• Use client.await_ready() to simplify blocking wait and add timeout to admin client (#2648)

  dpkp

  authored
  cf1cd10

  Copy full SHA for cf1cd10

Commits on Jun 18, 2025

• update README kafka version badge to include 4.0

  dpkp

  committed
  e4e6fcf

  Copy full SHA for e4e6fcf

• Patch Release 2.2.12

  dpkp

  committed
  e22e41e

  Copy full SHA for e22e41e

• Fix construction of final GSSAPI authentication message (#2647)

  dpkp

  authored
  0245352

  Copy full SHA for 0245352

• Avoid RuntimeError on mutated _completed_fetches deque in consumer fetcher (#2646)

  dpkp

  authored
  5d83941

  Copy full SHA for 5d83941

Commits on Jun 10, 2025

• Throw exception on invalid bucket type (#2642)

  Show description for 5c7cd2f
  emmanuel-ferdman

  authored
  5c7cd2f

  Copy full SHA for 5c7cd2f

Commits on Jun 5, 2025

• Patch Release 2.2.11

  dpkp

  committed
  3542e01

  Copy full SHA for 3542e01

• Do not ignore metadata response for single topic with error (#2640)

  dpkp

  authored
  e93ab64

  Copy full SHA for e93ab64

Commits on Jun 4, 2025

• Fix decoding bug in AWS_MSK_IAM mechanism (#2639)

  dpkp

  authored
  9f7384c

  Copy full SHA for 9f7384c

Commits on Jun 1, 2025

• Add synchronized decorator; add lock to subscription state (#2636)

  dpkp

  authored
  e6abbbf

  Copy full SHA for e6abbbf

Commits on May 24, 2025

• Update build links in documentation (#2634)

  boidolr

  authored
  5957c1b

  Copy full SHA for 5957c1b

Commits on May 22, 2025

• Patch Release 2.2.10

  dpkp

  committed
  6583460

  Copy full SHA for 6583460

• Pass host as kwarg to get_sasl_mechanism

  dpkp

  committed
  7fceb1b

  Copy full SHA for 7fceb1b

• Set the current host in the SASL configs (#2633)

  Show description for e2b6693
  

  SeppMe

  and

  SMeinhardt

  authored
  e2b6693

  Copy full SHA for e2b6693

• Fix sasl gssapi plugin: do not rely on client_ctx.complete in auth_bytes() (#2631)

  dpkp

  authored
  7b7f3af

  Copy full SHA for 7b7f3af

Commits on May 21, 2025

• Patch Release 2.2.9

  dpkp

  committed
  48dd596

  Copy full SHA for 48dd596

• More / updated debug logging for coordinator / consumer (#2630)

  dpkp

  authored
  bd21713

  Copy full SHA for bd21713

• Do not reset fetch positions if offset commit fetch times out (#2629)

  dpkp

  authored
  3463f59

  Copy full SHA for 3463f59

• Patch Release 2.2.8

  dpkp

  committed
  bcbd1b7

  Copy full SHA for bcbd1b7

• Dont mark coordinator dead on ThrottlingQuotaExceededError

  dpkp

  committed
  95c2f3a

  Copy full SHA for 95c2f3a

• Fix timeout seconds error message in KafkaProducer (#2627)

  dpkp

  authored
  62a7d80

  Copy full SHA for 62a7d80

Pagination

Previous

Next