Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

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

• Do not test fetched_size with fetch_max_bytes since 0.11 brokers will return more data than 0.10

  dpkp

  committed
  26a8102

  Copy full SHA for 26a8102

• Increase max_buffer_size for test_large_messages

  dpkp

  committed
  c5f1c69

  Copy full SHA for c5f1c69

• Fix fetch_max_bytes=1 consumer integration test

  dpkp

  committed
  b4f7122

  Copy full SHA for b4f7122

• Use fixture hostname (dont assume localhost)

  dpkp

  committed
  d127928

  Copy full SHA for d127928

• Add 0.11.0.0 server resources (reduced offsets.topic.replication.factor=1)

  dpkp

  committed
  6b316c0

  Copy full SHA for 6b316c0

Commits on Jun 17, 2017

• Describe consumer thread-safety

  

  Linus Wallgren

  authored and

  dpkp

  committed
  97261f4

  Copy full SHA for 97261f4

• Update exception docstring

  

  Andrew Kowalik

  authored and

  jeffwidman

  committed
  73d78bc

  Copy full SHA for 73d78bc

• raise KafkaTimeoutException when flush times out

  

  Andrew Kowalik

  authored and

  jeffwidman

  committed
  83f2d32

  Copy full SHA for 83f2d32

• Follow-up: support manual py26 testing; dont advertise 3.3 support

  dpkp

  committed
  bb626db

  Copy full SHA for bb626db

• Add kafka 0.10.2.1 into integration testing version (#1096)

  Show description for b1a6d33
  

  jianbin-wei

  authored and

  dpkp

  committed
  b1a6d33

  Copy full SHA for b1a6d33

Commits on May 3, 2017

• pylint 1.7.0+ supports python 3.6 and merge py36 into common tstenv (#1095)

  

  jianbin-wei

  authored and

  dpkp

  committed
  72205c4

  Copy full SHA for 72205c4

• Improve error message when expiring batches in KafkaProducer (#1077)

  dpkp

  authored
  a2b5ddc

  Copy full SHA for a2b5ddc

• Warn dont raise on DNS lookup failures (#1091)

  dpkp

  authored
  83617b9

  Copy full SHA for 83617b9

Commits on Apr 29, 2017

• Ignore not-context-manager pylint error (#1092)

  dpkp

  authored
  3844204

  Copy full SHA for 3844204

Commits on Apr 10, 2017

• Follow-up to #1068: remove not-implemented comments

  dpkp

  committed
  120410b

  Copy full SHA for 120410b

• readthedocs.io follow-up to #1074 for docs/

  dpkp

  committed
  a503682

  Copy full SHA for a503682

• Update RTD links with https / .io (#1074)

  

  jeffwidman

  authored and

  dpkp

  committed
  5bcb333

  Copy full SHA for 5bcb333

• Timeout idle connections via connections_max_idle_ms (#1068)

  dpkp

  authored
  0429699

  Copy full SHA for 0429699

Commits on Apr 6, 2017

• Avoid multiple connection attempts when refreshing metadata (#1067)

  dpkp

  authored
  7c24135

  Copy full SHA for 7c24135

Commits on Apr 5, 2017

• Catch socket.errors when sending / recving bytes on wake socketpair (#1069)

  dpkp

  authored
  bb9642f

  Copy full SHA for bb9642f

Commits on Mar 30, 2017

• Fix poll() hyperlink in KafkaClient

  Show description for d40d106
  jeffwidman

  committed
  d40d106

  Copy full SHA for d40d106

Commits on Mar 27, 2017

• Update README: Prefer python-lz4 over lz4tools (#1057)

  

  Kirill Ignatev

  authored and

  dpkp

  committed
  acbb510

  Copy full SHA for acbb510

Pagination

Previous

Next