Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 23, 2025

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

  dpkp

  authored
  be9dd7c

  Copy full SHA for be9dd7c

Commits on Apr 8, 2025

• Cluster.add_group_coordinator -> add_coordinator + support txn type

  dpkp

  committed
  cf1a999

  Copy full SHA for cf1a999

Commits on Mar 18, 2025

• Return empty set from consumer.partitions_for_topic when topic not found (#2556)

  dpkp

  authored
  9afaa41

  Copy full SHA for 9afaa41

Commits on Mar 12, 2025

• Improve ClusterMetadata docs re: node_id/broker_id str/int types

  dpkp

  committed
  227a312

  Copy full SHA for 227a312

Commits on Mar 5, 2025

• Add baseline leader_epoch support for ListOffsets v4 / FetchRequest v10 (#2511)

  dpkp

  authored
  f465adb

  Copy full SHA for f465adb

Commits on Mar 4, 2025

• Implement client-side connection throttling / KIP-219 (#2510)

  dpkp

  authored
  ad8d1c4

  Copy full SHA for ad8d1c4

Commits on Feb 27, 2025

• Support FindCoordinatorRequest v2 in consumer and admin client (#2502)

  dpkp

  authored
  62895a8

  Copy full SHA for 62895a8

Commits on Feb 26, 2025

• Add support for Metadata Request/Response v7 (#2497)

  dpkp

  authored
  a731b18

  Copy full SHA for a731b18

Commits on Feb 15, 2025

• Retain unrecognized broker response error codes with dynamic error class (#2481)

  dpkp

  authored
  3a0d5d6

  Copy full SHA for 3a0d5d6

Commits on Dec 30, 2019

• Do not log topic-specific errors in full metadata fetch (#1980)

  dpkp

  authored
  46882a8

  Copy full SHA for 46882a8

Commits on Jun 19, 2019

• Use dedicated connection for group coordinator (#1822)

  Show description for 91f4642
  

  dpkp

  authored and

  jeffwidman

  committed
  91f4642

  Copy full SHA for 91f4642

Commits on May 23, 2019

• Remove unused imports (#1808)

  jeffwidman

  authored
  edfafc0

  Copy full SHA for edfafc0

Commits on Mar 22, 2019

• Maintain shadow cluster metadata for bootstrapping (#1753)

  dpkp

  authored
  af2dd48

  Copy full SHA for af2dd48

Commits on Mar 14, 2019

• Retry bootstrapping after backoff when necessary (#1736)

  Show description for 812de35
  

  dpkp

  authored and

  jeffwidman

  committed
  812de35

  Copy full SHA for 812de35

Commits on May 26, 2018

• Ignore MetadataResponses with empty broker list (#1506)

  dpkp

  authored
  ee26c3f

  Copy full SHA for ee26c3f

Commits on May 23, 2018

• Document methods that return None

  Show description for c9d783a
  jeffwidman

  committed
  c9d783a

  Copy full SHA for c9d783a

Commits on Feb 6, 2018

• use absolute imports everywhere (#1362)

  

  kevinkjt2000

  authored and

  dpkp

  committed
  9ae0e59

  Copy full SHA for 9ae0e59

Commits on Feb 3, 2018

• KAFKA-3949: Avoid race condition when subscription changes during rebalance (#1364)

  dpkp

  authored
  618c505

  Copy full SHA for 618c505

Commits on Mar 7, 2017

• Add ClusterMetadata documentation

  dpkp

  committed
  a433816

  Copy full SHA for a433816

Commits on Mar 3, 2017

• Drop old brokers when rebuilding broker metadata (#1005)

  dpkp

  authored
  315850c

  Copy full SHA for 315850c

Commits on Aug 2, 2016

• Metadata with_partitions() (#787)

  Show description for 40e2faa
  dpkp

  authored
  40e2faa

  Copy full SHA for 40e2faa

Commits on Aug 1, 2016

• Vendor six 1.10.0

  dpkp

  committed
  51b3d31

  Copy full SHA for 51b3d31

Commits on Jul 17, 2016

• Use MetadataRequest v1 for 0.10+ api_version

  dpkp

  committed
  277f0dd

  Copy full SHA for 277f0dd

Commits on Jul 16, 2016

• Add rack to BrokerMetadata - it is always None when using MetadataRequest v0

  dpkp

  committed
  9960f3d

  Copy full SHA for 9960f3d

Commits on Jun 21, 2016

• Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)

  dpkp

  authored
  cbcb4a6

  Copy full SHA for cbcb4a6

Commits on Apr 5, 2016

• Remove unused imports

  dpkp

  committed
  c478d0c

  Copy full SHA for c478d0c

• Update imports from kafka.common -> kafka.errors / kafka.structs

  dpkp

  committed
  5a14bd8

  Copy full SHA for 5a14bd8

Commits on Feb 16, 2016

• Improve kafka.cluster docstrings

  dpkp

  committed
  d1daeaa

  Copy full SHA for d1daeaa

• Add lock to synchronize metadata updates and future handling

  dpkp

  committed
  742755d

  Copy full SHA for 742755d

• warn (not error) on LeaderNotAvailable - this is usually not cause for concern

  dpkp

  committed
  bd0caa7

  Copy full SHA for bd0caa7

• Update ClusterMetadata comments

  dpkp

  committed
  15b4b40

  Copy full SHA for 15b4b40

• Track set of unauthorized_topics in ClusterMetadata

  dpkp

  committed
  b4c36ee

  Copy full SHA for b4c36ee

• Remove unused cluster._version private attribute

  dpkp

  committed
  89b4c2f

  Copy full SHA for 89b4c2f

• Keep full PartitionMetadata from MetadataResponses

  dpkp

  committed
  ca7cd0d

  Copy full SHA for ca7cd0d

Commits on Feb 1, 2016

• Implement KafkaConsumer.topics()

  Show description for d3d6ea9
  dpkp

  committed
  d3d6ea9

  Copy full SHA for d3d6ea9

Pagination

Previous

Next