Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 19, 2024

• Remove all vendoring (#169)

  Show description for a856dc4
  s-t-e-v-e-n-k

  authored
  a856dc4

  Copy full SHA for a856dc4

Commits on Mar 18, 2024

• Run pyupgrade on everything. (#171)

  wbarnha

  authored
  fcca556

  Copy full SHA for fcca556

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

Commits on Jan 23, 2016

• Add available_partitions_for_topic() and partitions_for_broker()

  

  Dana Powers

  committed
  318b107

  Copy full SHA for 318b107

Commits on Jan 10, 2016

• Improve cluster.ttl() readability

  

  Dana Powers

  committed
  cc4cf23

  Copy full SHA for cc4cf23

Commits on Dec 30, 2015

• Switch configs from attributes to dict to make passing / inspecting easier

  

  Dana Powers

  committed
  3afdd28

  Copy full SHA for 3afdd28

Commits on Dec 28, 2015

• Add ClusterMetadata.add_group_coordinator()

  

  Dana Powers

  committed
  7c76138

  Copy full SHA for 7c76138

• Rename Cluster -> ClusterMetadata; align with upstream Metadata class

  

  Dana Powers

  committed
  cda2e17

  Copy full SHA for cda2e17

Commits on Dec 18, 2015

• Switch BrokerConnection to (mostly) non-blocking IO.

  Show description for f1ad024
  

  Dana Powers

  committed
  f1ad024

  Copy full SHA for f1ad024

Commits on Dec 4, 2015

• few small cleanups

  zackdever

  committed
  efc3d4f

  Copy full SHA for efc3d4f

Pagination

Previous

Next