Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 12, 2024

• Patch pylint warnings so tests pass again (#184)

  Show description for 5e461a7
  wbarnha

  authored
  5e461a7

  Copy full SHA for 5e461a7

Commits on Mar 26, 2024

• Use monkeytype to create some semblance of typing (#173)

  Show description for 56065da
  wbarnha

  authored
  56065da

  Copy full SHA for 56065da

Commits on Mar 20, 2024

• KIP-345 Static membership implementation (#137)

  Show description for 3c124b2
  

  3 peopleauthored
  3c124b2

  Copy full SHA for 3c124b2

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 Aug 4, 2023

• docs: Fix a few typos (#2319)

  Show description for 46473ba
  timgates42

  authored
  46473ba

  Copy full SHA for 46473ba

Commits on Nov 6, 2020

• Cover sticky assignor's metadata method with tests (#2161)

  aynroot

  authored
  b090b21

  Copy full SHA for b090b21

Commits on Oct 31, 2020

• Use six.viewitems instead of six.iteritems to avoid encoding problems (#2154)

  aynroot

  authored
  83b7b27

  Copy full SHA for 83b7b27

Commits on Sep 30, 2020

• KIP-54: Implement sticky partition assignment strategy (#2057)

  aynroot

  authored
  c536dd2

  Copy full SHA for c536dd2

Commits on Sep 7, 2020

• Fix #1985: fix consumer deadlock when heartbeat thread request timeout (#2064)

  huangcuiyang

  authored
  91daea3

  Copy full SHA for 91daea3

Commits on Jul 11, 2020

• remove unused imports

  

  jameslamb

  authored and

  jeffwidman

  committed
  316da74

  Copy full SHA for 316da74

Commits on Dec 30, 2019

• Optionally return OffsetAndMetadata from consumer.committed(tp) (#1979)

  dpkp

  authored
  2a86b23

  Copy full SHA for 2a86b23

Commits on Dec 29, 2019

• Log retriable coordinator NodeNotReady, TooManyInFlightRequests as debug not error (#1975)

  dpkp

  authored
  41d9f1c

  Copy full SHA for 41d9f1c

Commits on Dec 9, 2019

• Fix simple typo: managementment -> management

  Show description for 2ed01e9
  

  timgates42

  authored and

  jeffwidman

  committed
  2ed01e9

  Copy full SHA for 2ed01e9

Commits on Nov 8, 2019

• Fix typos

  

  carsonip

  authored and

  jeffwidman

  committed
  3861e16

  Copy full SHA for 3861e16

Commits on Sep 30, 2019

• Issue #1780 - Consumer hang indefinitely in fetcher._retrieve_offsets() due to topic deletion while rebalancing (#1782)

  

  royantman

  authored and

  dpkp

  committed
  298cb0d

  Copy full SHA for 298cb0d

• Change coordinator lock acquisition order (#1821)

  dpkp

  authored
  0f929bd

  Copy full SHA for 0f929bd

Commits on Sep 29, 2019

• Wrap consumer.poll() for KafkaConsumer iteration (#1902)

  dpkp

  authored
  5d1d424

  Copy full SHA for 5d1d424

Commits on Jun 20, 2019

• Allow the coordinator to auto-commit for all api_version.

  

  justecorruptio

  authored and

  jeffwidman

  committed
  5e055bc

  Copy full SHA for 5e055bc

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 17, 2019

• A little python cleanup (#1805)

  Show description for f854791
  jeffwidman

  authored
  f854791

  Copy full SHA for f854791

Commits on Mar 14, 2019

• Attempt to join heartbeat thread during close() (#1735)

  Show description for 921c553
  

  dpkp

  authored and

  jeffwidman

  committed
  921c553

  Copy full SHA for 921c553

Commits on Mar 13, 2019

• Ignore lookup_coordinator result in commit_offsets_async (#1712)

  

  asafflesch

  authored and

  dpkp

  committed
  994d283

  Copy full SHA for 994d283

Commits on Mar 8, 2019

• Do network connections and writes in KafkaClient.poll() (#1729)

  Show description for 8c07925
  dpkp

  authored
  8c07925

  Copy full SHA for 8c07925

Commits on Jan 15, 2019

• Improve KafkaConsumer join group / only enable Heartbeat Thread during stable group (#1695)

  dpkp

  authored
  a4f0cb8

  Copy full SHA for a4f0cb8

Commits on Nov 18, 2018

• Be explicit with tuples for %s formatting

  Show description for 1d44363
  jeffwidman

  committed
  1d44363

  Copy full SHA for 1d44363

Commits on Nov 10, 2018

• (Attempt to) Fix deadlock between consumer and heartbeat (#1628)

  dpkp

  authored
  0a2ccba

  Copy full SHA for 0a2ccba

Commits on Aug 31, 2018

• Return future from commit_offsets_async (#1560)

  

  ekimekim

  authored and

  dpkp

  committed
  5a04bc7

  Copy full SHA for 5a04bc7

Commits on Jun 5, 2018

• Don't use `kafka.common` internally

  Show description for bc4cc43
  jeffwidman

  committed
  bc4cc43

  Copy full SHA for bc4cc43

Commits on Apr 18, 2018

• Always acquire client lock before coordinator lock to avoid deadlocks (#1464)

  dpkp

  authored
  1c71dfc

  Copy full SHA for 1c71dfc

Commits on Mar 23, 2018

• Heartbeat thread start / close

  

  dpkp

  authored and

  jeffwidman

  committed
  4c87d11

  Copy full SHA for 4c87d11

• Change levels for some heartbeat thread logging

  

  dpkp

  authored and

  jeffwidman

  committed
  f18fd75

  Copy full SHA for f18fd75

• Check for immediate failure when looking up coordinator in heartbeat thread (#1457)

  dpkp

  authored
  204388b

  Copy full SHA for 204388b

Commits on Mar 11, 2018

• KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0 (#1439)

  dpkp

  authored
  9998604

  Copy full SHA for 9998604

Commits on Mar 10, 2018

• Remove old CommitFailed error message from coordinator (#1436)

  dpkp

  authored
  8bdbe92

  Copy full SHA for 8bdbe92

Pagination

Previous

Next