Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Oct 11, 2019

• Remove unused/empty .gitsubmodules file (#1928)

  Show description for cb7fd01
  jeffwidman

  authored
  cb7fd01

  Copy full SHA for cb7fd01

• Remove deprecated `ConnectionError` (#1816)

  Show description for f61b08c
  jeffwidman

  authored
  f61b08c

  Copy full SHA for f61b08c

• Remove SimpleClient, Producer, Consumer, Unittest (#1196)

  Show description for 3631bfa
  jeffwidman

  authored
  3631bfa

  Copy full SHA for 3631bfa

• Fix describe config for multi-broker clusters (#1869)

  Show description for 6d3800c
  

  jlandersen

  authored and

  jeffwidman

  committed
  6d3800c

  Copy full SHA for 6d3800c

Commits on Oct 7, 2019

• convert test_admin_integration to pytest (#1923)

  

  ulrikjohansson

  authored and

  jeffwidman

  committed
  84e37e0

  Copy full SHA for 84e37e0

Commits on Oct 3, 2019

• Update docstring to match conn.py's (#1921)

  

  David Bouchare

  authored and

  jeffwidman

  committed
  f1cda98

  Copy full SHA for f1cda98

Commits on Sep 30, 2019

• Release 1.4.7 (#1916)

  dpkp

  authored
  0552b04

  Copy full SHA for 0552b04

• Add KAFKA 2.3.0 to test matrix (#1915)

  dpkp

  authored
  0a8884b

  Copy full SHA for 0a8884b

• Follow up to PR 1782 -- fix tests (#1914)

  dpkp

  authored
  975087b

  Copy full SHA for 975087b

• Improve/refactor bootstrap_connected

  dpkp

  committed
  87fb1bb

  Copy full SHA for 87fb1bb

• Added a function to determine if bootstrap is successfully connected (#1876)

  

  Wayde2014

  authored and

  dpkp

  committed
  7a7a890

  Copy full SHA for 7a7a890

• 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

• Send socket data via non-blocking IO with send buffer (#1912)

  dpkp

  authored
  392d674

  Copy full SHA for 392d674

Commits on Sep 29, 2019

• Do not use wakeup when sending fetch requests from consumer (#1911)

  dpkp

  authored
  9de12d3

  Copy full SHA for 9de12d3

• Rely on socket selector to detect completed connection attempts (#1909)

  dpkp

  authored
  89bf6a6

  Copy full SHA for 89bf6a6

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

  dpkp

  authored
  5d1d424

  Copy full SHA for 5d1d424

• Skip admin integration tests -- travis fixture issues

  dpkp

  committed
  a9f513c

  Copy full SHA for a9f513c

• Update kafka.properties for ACL tests (0.11+ only)

  dpkp

  committed
  580fc0c

  Copy full SHA for 580fc0c

• Fix Admin Client api version checking; only test ACL integration on 0.11+

  dpkp

  committed
  98ebff8

  Copy full SHA for 98ebff8

Commits on Sep 28, 2019

• Fixup test_admin_integration test fixtures

  dpkp

  committed
  5381591

  Copy full SHA for 5381591

• Add ACL api to KafkaAdminClient (#1833)

  

  ulrikjohansson

  authored and

  dpkp

  committed
  76ad662

  Copy full SHA for 76ad662

Commits on Sep 25, 2019

• kafka-python: Fixed crc32c avilability on non-intel architectures. (#1904)

  Show description for 5e4d151
  

  ossdev07

  authored and

  jeffwidman

  committed
  5e4d151

  Copy full SHA for 5e4d151

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

Pagination

Previous

Next