Commits

Branch selector

 master

User selector

dpkp

Datepicker

All time

Commit History

Commits on Nov 21, 2018

• Bump version for development

  dpkp

  committed
  c6d8a53

  Copy full SHA for c6d8a53

• Release 1.4.4

  dpkp

  committed
  a3c5559

  Copy full SHA for a3c5559

Commits on Nov 20, 2018

• Update kafka broker compatibility docs

  dpkp

  committed
  45196e3

  Copy full SHA for 45196e3

• Bump travis test for 1.x brokers to 1.1.1

  dpkp

  committed
  4c520db

  Copy full SHA for 4c520db

• Add test resources for kafka versions 1.0.2 -> 2.0.1

  dpkp

  committed
  03b5995

  Copy full SHA for 03b5995

• Break KafkaClient poll if closed

  dpkp

  committed
  2c77c8d

  Copy full SHA for 2c77c8d

Commits on Nov 17, 2018

• Update requirements-dev to latest versions used on travis runs

  dpkp

  committed
  7bd6b5d

  Copy full SHA for 7bd6b5d

• Pin pytest on 3.x -- we arent ready for pytest 4.0 yet

  dpkp

  committed
  eae0edd

  Copy full SHA for eae0edd

Commits on Nov 13, 2018

• Update changelog

  dpkp

  committed
  f0ef99f

  Copy full SHA for f0ef99f

Commits on Nov 10, 2018

• (Attempt to) Fix deadlock between consumer and heartbeat (dpkp#1628)

  dpkp

  authored
  0a2ccba

  Copy full SHA for 0a2ccba

Commits on May 26, 2018

• Bump version for development

  dpkp

  committed
  81cda59

  Copy full SHA for 81cda59

• Release 1.4.3

  dpkp

  committed
  e81990b

  Copy full SHA for e81990b

• Retain but deprecate kafka.errors.ConnectionError for compatibility

  dpkp

  committed
  535d8f6

  Copy full SHA for 535d8f6

• Improve connection handling when bootstrap list is invalid (dpkp#1507)

  Show description for 39ebe1d
  dpkp

  authored
  39ebe1d

  Copy full SHA for 39ebe1d

• Ignore MetadataResponses with empty broker list (dpkp#1506)

  dpkp

  authored
  ee26c3f

  Copy full SHA for ee26c3f

Commits on Apr 18, 2018

• Skip flakey SimpleProducer test

  dpkp

  committed
  b6ffbaa

  Copy full SHA for b6ffbaa

• Always acquire client lock before coordinator lock to avoid deadlocks (dpkp#1464)

  dpkp

  authored
  1c71dfc

  Copy full SHA for 1c71dfc

Commits on Mar 23, 2018

• Heartbeat thread start / close

  

  dpkp

  authored and

  jeffwidman

  committed
  4c87d11

  Copy full SHA for 4c87d11

• Change levels for some heartbeat thread logging

  

  dpkp

  authored and

  jeffwidman

  committed
  f18fd75

  Copy full SHA for f18fd75

• Fix KafkaConsumer docstring for request_timeout_ms default (dpkp#1459)

  dpkp

  authored
  c0fddbd

  Copy full SHA for c0fddbd

• Change SimpleProducer to use async_send (async is reserved in py37) (dpkp#1454)

  dpkp

  authored
  b62006a

  Copy full SHA for b62006a

• Check for immediate failure when looking up coordinator in heartbeat thread (dpkp#1457)

  dpkp

  authored
  204388b

  Copy full SHA for 204388b

• Fix skipped integration tests if KAFKA_VERSION unset (dpkp#1453)

  dpkp

  authored
  e8cb888

  Copy full SHA for e8cb888

Commits on Mar 11, 2018

• KAFKA-5512; Awake the heartbeat thread when timetoNextHeartbeat is equal to 0 (dpkp#1439)

  dpkp

  authored
  9998604

  Copy full SHA for 9998604

Commits on Mar 10, 2018

• Add kafka 1.0.1 release to test fixtures (dpkp#1437)

  dpkp

  authored
  c920a2a

  Copy full SHA for c920a2a

• Remove old CommitFailed error message from coordinator (dpkp#1436)

  dpkp

  authored
  8bdbe92

  Copy full SHA for 8bdbe92

• Validate that serializers generate bytes-like (or None) data (dpkp#1420)

  dpkp

  authored
  b8d40b5

  Copy full SHA for b8d40b5

• Do not validate api_version against known versions (dpkp#1434)

  dpkp

  authored
  22e3f75

  Copy full SHA for 22e3f75

• Connect with sockaddrs to support non-zero ipv6 scope ids (dpkp#1433)

  dpkp

  authored
  acbc346

  Copy full SHA for acbc346

Commits on Mar 9, 2018

• Re-enable logging during broker version check (dpkp#1430)

  dpkp

  authored
  3dc536a

  Copy full SHA for 3dc536a

• Connection logging cleanups (dpkp#1432)

  dpkp

  authored
  eb941ee

  Copy full SHA for eb941ee

• Add BrokerConnection.connect_blocking() (dpkp#1411)

  dpkp

  authored
  1ffdd5c

  Copy full SHA for 1ffdd5c

• Short-circuit BrokerConnection.close() if already disconnected (dpkp#1424)

  dpkp

  authored
  4cbeb2e

  Copy full SHA for 4cbeb2e

• Only increase reconnect backoff if all addrinfos have been tried (dpkp#1423)

  dpkp

  authored
  1974dc1

  Copy full SHA for 1974dc1

• Close leaked selector in version check (dpkp#1425)

  dpkp

  authored
  d90cf22

  Copy full SHA for d90cf22

Pagination

Previous

Next