Commits

Branch selector

 protocol_updates

User selector

All users

Datepicker

All time

Commit History

Commits on Jun 20, 2017

• Cleanup protocol change comments

  dpkp

  committed
  cf8c034

  Copy full SHA for cf8c034

Commits on Jun 19, 2017

• Add new protocol definitions for 0.11.0.0

  dpkp

  committed
  2533680

  Copy full SHA for 2533680

• Add new FetchRequest v4/v5, MetadataRequest v3/v4

  dpkp

  committed
  3a67f64

  Copy full SHA for 3a67f64

• 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

• Fix typo (#1054)

  

  jeffwidman

  authored and

  dpkp

  committed
  bee0bbe

  Copy full SHA for bee0bbe

Commits on Mar 14, 2017

• Bump version for development

  dpkp

  committed
  998147d

  Copy full SHA for 998147d

• Release 1.3.3

  dpkp

  committed
  0e24da3

  Copy full SHA for 0e24da3

• Derive all api classes from Request / Response base classes (#1030)

  dpkp

  authored
  65ba882

  Copy full SHA for 65ba882

• Alter test skips: python-lz4 works on python26, but not pypy

  dpkp

  committed
  a00f9ea

  Copy full SHA for a00f9ea

• LZ4 support in kafka 0.8/0.9 does not accept a ContentSize header

  dpkp

  committed
  fea10d9

  Copy full SHA for fea10d9

• Prefer python-lz4 over lz4f if available

  dpkp

  committed
  fb023fe

  Copy full SHA for fb023fe

• Free lz4 decompression context to avoid leak

  dpkp

  committed
  3b899de

  Copy full SHA for 3b899de

Pagination

Previous

Next