Commits

Branch selector

 sort-partitions

User selector

All users

Datepicker

All time

Commit History

Commits on Dec 19, 2016

• Don't convert to list twice

  ms7s

  committed
  4003949

  Copy full SHA for 4003949

Commits on Dec 6, 2016

• Sort partitions before calling partitioner

  Show description for 37c766a
  ms7s

  committed
  37c766a

  Copy full SHA for 37c766a

Commits on Dec 3, 2016

• Fix possible request draining in ensure_active_group (#896)

  dpkp

  authored
  010ebb5

  Copy full SHA for 010ebb5

Commits on Nov 30, 2016

• DOC: Fix typo 'Defualt' -> 'Default'. (#895)

  

  rolando

  authored and

  dpkp

  committed
  9b59c5d

  Copy full SHA for 9b59c5d

Commits on Nov 20, 2016

• When hostname lookup is necessary, do every connect (#812)

  Show description for cbe8a6a
  

  Evan Bender

  authored and

  dpkp

  committed
  cbe8a6a

  Copy full SHA for cbe8a6a

• Use six.string_types for topic type check in #824

  dpkp

  committed
  c4a6e1a

  Copy full SHA for c4a6e1a

• Raise exception if given a bad topic name (#824)

  

  ssaamm

  authored and

  dpkp

  committed
  5ad6f52

  Copy full SHA for 5ad6f52

• Added doc for `max_poll_records` option (#881)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  07237d9

  Copy full SHA for 07237d9

Commits on Nov 18, 2016

• setting proper topic value in case if it's empty (#867)

  

  sibiryakov

  authored and

  dpkp

  committed
  af7f2ce

  Copy full SHA for af7f2ce

• Always include an error for logging when the coordinator is marked dead (#890)

  dpkp

  authored
  6bd1e1d

  Copy full SHA for 6bd1e1d

• Args are optional in BrokerResponseError str (#889)

  dpkp

  authored
  ff56bdb

  Copy full SHA for ff56bdb

• :wPass timestamp into Message, not just mimic it (#875)

  

  tvoinarovskyi

  authored and

  dpkp

  committed
  6c9f728

  Copy full SHA for 6c9f728

• Always check for request timeouts (#887)

  Show description for f71cfc4
  dpkp

  authored
  f71cfc4

  Copy full SHA for f71cfc4

Commits on Nov 15, 2016

• typo (#883)

  Show description for 57ea7e8
  

  sharego

  authored and

  dpkp

  committed
  57ea7e8

  Copy full SHA for 57ea7e8

Commits on Nov 14, 2016

• Update param in warning (#878)

  Show description for 43e0c38
  dpkp

  authored
  43e0c38

  Copy full SHA for 43e0c38

• Remove old design notes from Kafka 8 era (#876)

  

  jeffwidman

  authored and

  dpkp

  committed
  eb6801d

  Copy full SHA for eb6801d

• Fix typos (#874)

  dpkp

  authored
  8ac79fb

  Copy full SHA for 8ac79fb

• Fix typos

  jeffwidman

  committed
  cd74c1f

  Copy full SHA for cd74c1f

Commits on Nov 12, 2016

• Update param in warning

  Show description for 13150a6
  jeffwidman

  authored
  13150a6

  Copy full SHA for 13150a6

Commits on Oct 24, 2016

• Revert consumer iterators from max_poll_records (#856)

  dpkp

  authored
  77591af

  Copy full SHA for 77591af

Commits on Oct 22, 2016

• Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)

  Show description for 8de40a2
  dpkp

  authored
  8de40a2

  Copy full SHA for 8de40a2

Commits on Oct 4, 2016

• Bugfix on max_poll_records - TypeError: object of type NoneType has no len()

  dpkp

  committed
  9450a6b

  Copy full SHA for 9450a6b

Commits on Sep 28, 2016

• KAFKA-3007: KafkaConsumer max_poll_records (#831)

  dpkp

  authored
  9ee77df

  Copy full SHA for 9ee77df

• Update Partitioners for use with KafkaProducer (#827)

  

  barrotsteindev

  authored and

  dpkp

  committed
  b8717b4

  Copy full SHA for b8717b4

• Monkeypatch max_in_flight_requests_per_connection when checking broker version (#834)

  dpkp

  authored
  5c78489

  Copy full SHA for 5c78489

Commits on Sep 15, 2016

• Fix message timestamp_type (#828)

  

  qix

  authored and

  dpkp

  committed
  2a7aca1

  Copy full SHA for 2a7aca1

• Added ssl_password config option to KafkaProducer class, identical to… (#830)

  Show description for 1646edf
  

  kierkegaard13

  authored and

  dpkp

  committed
  1646edf

  Copy full SHA for 1646edf

Commits on Sep 4, 2016

• from kafka import ConsumerRebalanceListener, OffsetAndMetadata

  dpkp

  committed
  1937ce5

  Copy full SHA for 1937ce5

Commits on Aug 21, 2016

• Fix quota violation exception message (#809)

  dpkp

  authored
  7d31aa3

  Copy full SHA for 7d31aa3

• Improve KafkaProducer docstring re retries config

  dpkp

  committed
  754ff89

  Copy full SHA for 754ff89

Commits on Aug 20, 2016

• Add comment for round robin partitioner with different subscriptions

  dpkp

  committed
  e50d4dd

  Copy full SHA for e50d4dd

Commits on Aug 12, 2016

• Use 0.10.0.1 for integration tests (#803)

  Show description for e5c6487
  dpkp

  authored
  e5c6487

  Copy full SHA for e5c6487

Commits on Aug 11, 2016

• Bump version for development

  dpkp

  committed
  1662c63

  Copy full SHA for 1662c63

Commits on Aug 9, 2016

• Patch Release 1.3.1

  dpkp

  committed
  221fa65

  Copy full SHA for 221fa65

• HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reconnects) (#799)

  dpkp

  authored
  a71bee5

  Copy full SHA for a71bee5

Pagination

Previous

Next