Commits

Branch selector

 master

User selector

All users

All time

Commit History

Commits on Aug 15, 2017

• BrokerConnection receive bytes pipe (#1032)

  dpkp

  authored
  ba7afd9

  Copy full SHA for ba7afd9

• Drop unused sleep kwarg to poll (#1177)

  dpkp

  authored
  cbc6fdc

  Copy full SHA for cbc6fdc

Commits on Aug 13, 2017

• Update sphinx/RTD changelog for 1.3.4

  dpkp

  committed
  497ded9

  Copy full SHA for 497ded9

• bump version for development

  dpkp

  committed
  62fc50b

  Copy full SHA for 62fc50b

• Update compatibility docs re: 0.11 brokers and python 3.6

  dpkp

  committed
  b51fc88

  Copy full SHA for b51fc88

• Release 1.3.4

  dpkp

  committed
  8f46ae8

  Copy full SHA for 8f46ae8

• Add 0.11.0.0 to travis test matrix, remove 0.10.1.1; use scala 2.11 artifacts (#1176)

  dpkp

  authored
  b66f927

  Copy full SHA for b66f927

• Initialize metadata_snapshot in group coordinator (#1174)

  dpkp

  authored
  4b32b2e

  Copy full SHA for 4b32b2e

• Select on sockets to avoid busy polling during bootstrap (#1175)

  dpkp

  authored
  422189b

  Copy full SHA for 422189b

Commits on Aug 7, 2017

• Merge pull request #1161 from dpkp/issue1036_offset_by_time

  Show description for 8cf4484
  tvoinarovskyi

  authored
  8cf4484

  Copy full SHA for 8cf4484

• Added unit tests for fetcher's `_reset_offset` and related functions.

  tvoinarovskyi

  committed
  55ded55

  Copy full SHA for 55ded55

• Added `beginning_offsets` and `end_offsets` API's and fixed @jeffwidman review issues

  tvoinarovskyi

  committed
  1f69f8f

  Copy full SHA for 1f69f8f

• Fix test for older brokers

  tvoinarovskyi

  committed
  efc03d0

  Copy full SHA for efc03d0

• Changed retrieve_offsets to allow fetching multiple offsets at once

  tvoinarovskyi

  committed
  63992f9

  Copy full SHA for 63992f9

• Fix test for older brokers

  tvoinarovskyi

  committed
  f244e52

  Copy full SHA for f244e52

• Added basic support for offsets_for_times API. Still needs to group by nodes and send in parallel.

  tvoinarovskyi

  committed
  39f0e50

  Copy full SHA for 39f0e50

• Add private map of api key -> min/max versions to BrokerConnection (#1169)

  dpkp

  authored
  da25df6

  Copy full SHA for da25df6

Commits on Aug 5, 2017

• Fixed Issue 1033.Raise AssertionError when decompression unsupported. (#1159)

  

  bts-webber

  authored and

  dpkp

  committed
  6b97eae

  Copy full SHA for 6b97eae

Commits on Aug 1, 2017

• conn: Catch ssl.EOFErrors on Python3.3 so we close the failing conn (#1162)

  

  Ormod

  authored and

  dpkp

  committed
  3ff3d75

  Copy full SHA for 3ff3d75

Commits on Jul 30, 2017

• Merge pull request #1160 from dpkp/issue1155

  Show description for 1664374
  tvoinarovskyi

  authored
  1664374

  Copy full SHA for 1664374

• Make UnknownTopicOrPartitionError retriable error

  tvoinarovskyi

  committed
  9868ab0

  Copy full SHA for 9868ab0

Commits on Jul 26, 2017

• Fix batch expiry messages to state seconds

  Show description for ca02bb1
  

  dnwe

  authored and

  jeffwidman

  committed
  ca02bb1

  Copy full SHA for ca02bb1

Commits on Jul 21, 2017

• Use for join-time-max and sync-time-max metrics Max() measure function (#1146)

  

  billyevans

  authored and

  dpkp

  committed
  165b897

  Copy full SHA for 165b897

Commits on Jul 20, 2017

• added gssapi support (Kerberos) for SASL (#1152)

  

  Harald-Berghoff

  authored and

  dpkp

  committed
  0c78f70

  Copy full SHA for 0c78f70

Commits on Jul 17, 2017

• Add note, that `max_in_flight_requests_per_connection>1` may change order or messages (#1149)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  c8237fc

  Copy full SHA for c8237fc

• producer: fix produce timeout message (#1151)

  

  Mika Eloranta

  authored and

  dpkp

  committed
  6f03957

  Copy full SHA for 6f03957

Commits on Jul 9, 2017

• Protocol updates for 0.11.0.0 (#1127)

  dpkp

  authored
  d0c6b1f

  Copy full SHA for d0c6b1f

Commits on Jul 7, 2017

• Use logging's built-in string interpolation

  jeffwidman

  committed
  2f75169

  Copy full SHA for 2f75169

• change_subscription called only when necessary (#1132)

  Show description for 43939b2
  

  Artimi

  authored and

  dpkp

  committed
  43939b2

  Copy full SHA for 43939b2

Commits on Jul 1, 2017

• Fix typo

  jeffwidman

  authored
  71ce772

  Copy full SHA for 71ce772

Commits on Jun 20, 2017

• producer: Set exit timeout to 0 for atexit handler to match __del__ (#1126)

  Show description for b8da199
  

  Ormod

  authored and

  dpkp

  committed
  b8da199

  Copy full SHA for b8da199

Commits on Jun 19, 2017

• KIP-144: Exponential backoff for broker reconnections (#1124)

  dpkp

  authored
  b1cc966

  Copy full SHA for b1cc966

• Backoff on unavailable group coordinator retry (#1125)

  dpkp

  authored
  cceaf4a

  Copy full SHA for cceaf4a

• Fixup for #1085 -- only check for changed metadata on disconnected nodes

  dpkp

  committed
  bbbac3d

  Copy full SHA for bbbac3d

• Deal with brokers that disappear, reappear with different IP address (#1085)

  Show description for 2a41fa1
  

  kaiterramike

  authored and

  dpkp

  committed
  2a41fa1

  Copy full SHA for 2a41fa1