Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 5, 2019

• Sanity test for consumer.topics() and consumer.partitions_for_topic()

  

  Baisang

  authored and

  jeffwidman

  committed
  f126e5b

  Copy full SHA for f126e5b

Commits on May 30, 2019

• Delay converting to seconds

  Show description for 79dd508
  jeffwidman

  committed
  79dd508

  Copy full SHA for 79dd508

• Reduce client poll timeout when no ifrs

  

  dpkp

  authored and

  jeffwidman

  committed
  9f0b518

  Copy full SHA for 9f0b518

• Catch TimeoutError in BrokerConnection send/recv (#1820)

  dpkp

  authored
  5bb1abd

  Copy full SHA for 5bb1abd

Commits on May 29, 2019

• Remove unused/weird comment line (#1813)

  jeffwidman

  authored
  21b00c3

  Copy full SHA for 21b00c3

Commits on May 24, 2019

• Update docs for api_version_auto_timeout_ms (#1812)

  Show description for cee4d17
  jeffwidman

  committed
  cee4d17

  Copy full SHA for cee4d17

Commits on May 23, 2019

• Fix typo in _fetch_all_topic_metadata function (#1809)

  

  Baisang

  authored and

  jeffwidman

  committed
  1a0f297

  Copy full SHA for 1a0f297

• Make partitions_for_topic a read-through cache (#1781)

  Show description for 1f73287
  

  Baisang

  authored and

  jeffwidman

  committed
  1f73287

  Copy full SHA for 1f73287

• Remove unused imports (#1808)

  jeffwidman

  authored
  edfafc0

  Copy full SHA for edfafc0

Commits on May 21, 2019

• Use futures to parallelize calls to _send_request_to_node() (#1807)

  Show description for f145e37
  

  davidheitman

  authored and

  jeffwidman

  committed
  f145e37

  Copy full SHA for f145e37

Commits on May 17, 2019

• Update link to kafka docs

  Show description for 1b6c9c7
  jeffwidman

  authored
  1b6c9c7

  Copy full SHA for 1b6c9c7

• A little python cleanup (#1805)

  Show description for f854791
  jeffwidman

  authored
  f854791

  Copy full SHA for f854791

Commits on Apr 3, 2019

• Bump version for development of next release

  dpkp

  committed
  f6a8a38

  Copy full SHA for f6a8a38

• Release 1.4.6

  dpkp

  committed
  be7f935

  Copy full SHA for be7f935

• Do not call state_change_callback with lock (#1775)

  dpkp

  authored
  91d3149

  Copy full SHA for 91d3149

Commits on Apr 2, 2019

• Additional BrokerConnection locks to synchronize protocol/IFR state (#1768)

  dpkp

  authored
  27cd93b

  Copy full SHA for 27cd93b

• Return connection state explicitly after close in connect() (#1778)

  dpkp

  authored
  ed4cab6

  Copy full SHA for ed4cab6

• Reset reconnect backoff on SSL connection (#1777)

  dpkp

  authored
  6ca6f36

  Copy full SHA for 6ca6f36

• Fix possible AttribueError during conn._close_socket (#1776)

  dpkp

  authored
  827dee2

  Copy full SHA for 827dee2

• Dont treat popped conn.close() as failure in state change callback (#1773)

  dpkp

  authored
  51313d7

  Copy full SHA for 51313d7

Commits on Apr 1, 2019

• Avoid race condition on client._conns in send() (#1772)

  Show description for c02df4b
  

  dpkp

  authored and

  jeffwidman

  committed
  c02df4b

  Copy full SHA for c02df4b

• lock client.check_version (#1771)

  dpkp

  authored
  3664ae8

  Copy full SHA for 3664ae8

Commits on Mar 31, 2019

• Dont wakeup during maybe_refresh_metadata -- it is only called by poll() (#1769)

  dpkp

  authored
  b1effa2

  Copy full SHA for b1effa2

Commits on Mar 30, 2019

• Fixups to benchmark scripts for py3 / new KafkaFixture interface

  dpkp

  committed
  de6e9d3

  Copy full SHA for de6e9d3

Commits on Mar 27, 2019

• Revert 703f0659 / fix 0.8.2 protocol quick detection (#1763)

  dpkp

  authored
  227a946

  Copy full SHA for 227a946

• Send pending requests before waiting for responses (#1762)

  dpkp

  authored
  e45b89b

  Copy full SHA for e45b89b

Commits on Mar 24, 2019

• Rename ssl.keystore.location and ssl.truststore.location config files

  dpkp

  committed
  8602389

  Copy full SHA for 8602389

• Dont do client wakeup when sending from sender thread (#1761)

  dpkp

  authored
  d388b48

  Copy full SHA for d388b48

• Update sasl configuration docstrings

  dpkp

  committed
  ce9c1d2

  Copy full SHA for ce9c1d2

Commits on Mar 23, 2019

• Support SASL OAuthBearer Authentication (#1750)

  

  pt2pham

  authored and

  dpkp

  committed
  8e2ed3e

  Copy full SHA for 8e2ed3e

Commits on Mar 22, 2019

• Fix flaky conn tests that use time.time (#1758)

  dpkp

  authored
  d032844

  Copy full SHA for d032844

• Add py to requirements-dev

  dpkp

  committed
  d620703

  Copy full SHA for d620703

• Maintain shadow cluster metadata for bootstrapping (#1753)

  dpkp

  authored
  af2dd48

  Copy full SHA for af2dd48

• Allow configuration of SSL Ciphers (#1755)

  

  dpkp

  authored and

  jeffwidman

  committed
  0bc7518

  Copy full SHA for 0bc7518

• Wrap SSL sockets after connecting (#1754)

  dpkp

  authored
  f2f2bfe

  Copy full SHA for f2f2bfe

Pagination

Previous

Next