Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Sep 27, 2018

• Support produce with Kafka record headers

  

  hnousiainen

  authored and

  jeffwidman

  committed
  08c7749

  Copy full SHA for 08c7749

• Expose record headers in ConsumerRecords

  

  hnousiainen

  authored and

  jeffwidman

  committed
  0ca4313

  Copy full SHA for 0ca4313

• Add positive tests for headers in record encode/decode

  

  hnousiainen

  authored and

  jeffwidman

  committed
  9d30ab8

  Copy full SHA for 9d30ab8

• Expose ConsumerRebalanceListener in all

  Show description for 5825c67
  

  ben-harack

  authored and

  jeffwidman

  committed
  5825c67

  Copy full SHA for 5825c67

• Remove ConsumerTimeout

  

  emord

  authored and

  jeffwidman

  committed
  ba7372e

  Copy full SHA for ba7372e

Commits on Aug 31, 2018

• Clear the metrics dictionary on close. (#1569)

  

  kishorenc

  authored and

  dpkp

  committed
  5068229

  Copy full SHA for 5068229

• Return future from commit_offsets_async (#1560)

  

  ekimekim

  authored and

  dpkp

  committed
  5a04bc7

  Copy full SHA for 5a04bc7

• add kerberos domain name config for gssapi sasl mechanism handshake (#1542)

  

  the-sea

  authored and

  dpkp

  committed
  36b53f4

  Copy full SHA for 36b53f4

• add support for smaller topic metadata fetch during bootstrap (#1541)

  

  andyxning

  authored and

  dpkp

  committed
  a7d3063

  Copy full SHA for a7d3063

Commits on Jun 26, 2018

• Document connections_max_idle_ms

  Show description for 9ac3cb1
  jeffwidman

  committed
  9ac3cb1

  Copy full SHA for 9ac3cb1

Commits on Jun 5, 2018

• Don't use `kafka.common` internally

  Show description for bc4cc43
  jeffwidman

  committed
  bc4cc43

  Copy full SHA for bc4cc43

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 (#1507)

  Show description for 39ebe1d
  dpkp

  authored
  39ebe1d

  Copy full SHA for 39ebe1d

• Ignore MetadataResponses with empty broker list (#1506)

  dpkp

  authored
  ee26c3f

  Copy full SHA for ee26c3f

Commits on May 23, 2018

• Document methods that return None

  Show description for c9d783a
  jeffwidman

  committed
  c9d783a

  Copy full SHA for c9d783a

• Stop shadowing `ConnectionError`

  Show description for 11cf397
  jeffwidman

  committed
  11cf397

  Copy full SHA for 11cf397

Commits on May 10, 2018

• Stop using deprecated log.warn()

  jeffwidman

  committed
  9221fcf

  Copy full SHA for 9221fcf

Commits on Apr 24, 2018

• Minor doc capitalization cleanup

  jeffwidman

  authored
  27f939a

  Copy full SHA for 27f939a

Commits on Apr 19, 2018

• Force lz4 to disable Kafka-unsupported block linking when encoding (#1476)

  

  mnito

  authored and

  dpkp

  committed
  afc6346

  Copy full SHA for afc6346

Commits on Apr 18, 2018

• Skip flakey SimpleProducer test

  dpkp

  committed
  b6ffbaa

  Copy full SHA for b6ffbaa

• Added AlterConfigs and DescribeConfigs apis (#1472)

  

  StephenSorriaux

  authored and

  dpkp

  committed
  59b0c6f

  Copy full SHA for 59b0c6f

• Add codec validators to record parser and builder for all formats (#1447)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  908ac8f

  Copy full SHA for 908ac8f

• Fix MemoryRecord bugs re error handling and add test coverage (#1448)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  d9e41c8

  Copy full SHA for d9e41c8

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

  dpkp

  authored
  1c71dfc

  Copy full SHA for 1c71dfc

Commits on Apr 16, 2018

• Improve BrokerConnection initialization (#1475)

  

  romulorosa

  authored and

  dpkp

  committed
  e23676d

  Copy full SHA for e23676d

Commits on Apr 5, 2018

• Fix CreatePartitionsRequest_v0 (#1469)

  

  StephenSorriaux

  authored and

  dpkp

  committed
  6163aa3

  Copy full SHA for 6163aa3

Commits on Mar 29, 2018

• Adds add_callback/add_errback example to docs (#1441)

  

  Berkodev

  authored and

  dpkp

  committed
  4267ed5

  Copy full SHA for 4267ed5

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 (#1459)

  dpkp

  authored
  c0fddbd

  Copy full SHA for c0fddbd

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

  dpkp

  authored
  b62006a

  Copy full SHA for b62006a

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

  dpkp

  authored
  204388b

  Copy full SHA for 204388b

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

  dpkp

  authored
  e8cb888

  Copy full SHA for e8cb888

Pagination

Previous

Next