Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 3, 2019

• Improve connection lock handling; always use context manager (#1895)

  dpkp

  authored
  7a69952

  Copy full SHA for 7a69952

Commits on Aug 23, 2019

• Convert remaining `KafkaConsumer` tests to `pytest` (#1886)

  Show description for 61fa0b2
  jeffwidman

  authored
  61fa0b2

  Copy full SHA for 61fa0b2

• Bump integration tests to 0.10.2.2 and 0.11.0.3 (#1890)

  Show description for 6e6d0cc
  jeffwidman

  authored
  6e6d0cc

  Copy full SHA for 6e6d0cc

Commits on Aug 22, 2019

• Cleanup handling of KAFKA_VERSION env var in tests (#1887)

  Show description for 98c0058
  jeffwidman

  authored
  98c0058

  Copy full SHA for 98c0058

• Minor test cleanup (#1885)

  Show description for e49caeb
  jeffwidman

  authored
  e49caeb

  Copy full SHA for e49caeb

Commits on Aug 16, 2019

• Reduce internal client poll timeout for consumer iterator interface (#1824)

  Show description for 5bc2529
  

  dpkp

  authored and

  jeffwidman

  committed
  5bc2529

  Copy full SHA for 5bc2529

• Update conn.py

  

  iAnomaly

  authored and

  jeffwidman

  committed
  ace6af5

  Copy full SHA for ace6af5

Commits on Aug 15, 2019

• tests: Use socket.SOCK_STREAM in assertions

  Show description for 2180d31
  

  iv-m

  authored and

  jeffwidman

  committed
  2180d31

  Copy full SHA for 2180d31

Commits on Jul 31, 2019

• Break FindCoordinator into request/response methods

  Show description for ea35fdf
  jeffwidman

  committed
  ea35fdf

  Copy full SHA for ea35fdf

Commits on Jul 14, 2019

• Fix minor typo (#1865)

  

  carsonip

  authored and

  dpkp

  committed
  eed25fc

  Copy full SHA for eed25fc

Commits on Jul 11, 2019

• Update link to upstream Kafka docs

  Show description for fb87a35
  jeffwidman

  authored
  fb87a35

  Copy full SHA for fb87a35

Commits on Jun 28, 2019

• Add the `sasl_kerberos_domain_name` arg to `KafkaAdminClient`

  Show description for 279a7dd
  jeffwidman

  committed
  279a7dd

  Copy full SHA for 279a7dd

Commits on Jun 21, 2019

• Update KafkaAdminClient Docs

  Show description for 5a72a62
  

  cardy31

  authored and

  jeffwidman

  committed
  5a72a62

  Copy full SHA for 5a72a62

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

• Break consumer operations into request / response methods (#1845)

  Show description for 01053da
  jeffwidman

  authored
  01053da

  Copy full SHA for 01053da

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 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

Pagination

Previous

Next