Commits

Breadcrumbs

History for

onmaster

User selector

All users

Datepicker

All time

Commit History

Commits on Mar 24, 2025

• Move ensure_valid_topic_name to kafka.util; use in client and producer (#2561)

  dpkp

  authored
  d214321

  Copy full SHA for d214321

Commits on Mar 15, 2025

• Add optional timeout_ms kwarg to remaining consumer/coordinator methods (#2544)

  dpkp

  authored
  3493380

  Copy full SHA for 3493380

Commits on Mar 13, 2025

• Move inner_timeout_ms def to kafka.util timeout_ms_fn

  dpkp

  committed
  693b210

  Copy full SHA for 693b210

Commits on Feb 6, 2020

• Remove unused import

  Show description for 3d98741
  jeffwidman

  committed
  3d98741

  Copy full SHA for 3d98741

Commits on Feb 5, 2020

• Remove some dead code

  jeffwidman

  committed
  6babefa

  Copy full SHA for 6babefa

Commits on Oct 11, 2019

• Remove SimpleClient, Producer, Consumer, Unittest (#1196)

  Show description for 3631bfa
  jeffwidman

  authored
  3631bfa

  Copy full SHA for 3631bfa

Commits on Oct 22, 2018

• Update remote urls: snappy, https, etc

  Show description for a6be21e
  jeffwidman

  committed
  a6be21e

  Copy full SHA for a6be21e

Commits on Jan 10, 2018

• Improve KafkaConsumer cleanup (#1339)

  dpkp

  authored
  0a74924

  Copy full SHA for 0a74924

Commits on Dec 9, 2017

• Followup cleanup to #1304

  Show description for 04fb37f
  jeffwidman

  authored
  04fb37f

  Copy full SHA for 04fb37f

Commits on Dec 8, 2017

• optimize util.crc32 (#1304)

  

  ofek

  authored and

  dpkp

  committed
  2c8748c

  Copy full SHA for 2c8748c

Commits on Feb 28, 2017

• Remove dead code (#967)

  

  jeffwidman

  authored and

  dpkp

  committed
  2c23a27

  Copy full SHA for 2c23a27

Commits on Aug 3, 2016

• Always absolute_import

  dpkp

  committed
  c693709

  Copy full SHA for c693709

Commits on Aug 1, 2016

• Vendor six 1.10.0

  dpkp

  committed
  51b3d31

  Copy full SHA for 51b3d31

Commits on Jun 18, 2016

• Use weakref when registering a producer.close atexit to fix normal gc (#728)

  Show description for 6271c02
  dpkp

  authored
  6271c02

  Copy full SHA for 6271c02

Commits on Apr 5, 2016

• Update imports from kafka.common -> kafka.errors / kafka.structs

  dpkp

  committed
  5a14bd8

  Copy full SHA for 5a14bd8

Commits on Feb 17, 2016

• break up some circular references and close client wake pipe on __del__

  

  aisch

  committed
  d7522b0

  Copy full SHA for d7522b0

Commits on Dec 11, 2015

• Drop kafka_bytestring

  

  Dana Powers

  committed
  d54980a

  Copy full SHA for d54980a

Commits on Dec 4, 2015

• Switch crc32 back to signed integer -- this is consistent with protocol encoding spec

  

  Dana Powers

  authored and

  zackdever

  committed
  f08775a

  Copy full SHA for f08775a

Commits on Jun 6, 2015

• Raise an error if we attempt to group duplicate topic-partition payloads

  Show description for 868115c
  

  Dana Powers

  committed
  868115c

  Copy full SHA for 868115c

Commits on Mar 2, 2015

• Stopping daemonized threads when references to these threads are lost

  chmduquesne

  committed
  0497924

  Copy full SHA for 0497924

Commits on Feb 3, 2015

• Fix python2.6 threading.Event bug in ReentrantTimer

  

  Dana Powers

  committed
  a21f701

  Copy full SHA for a21f701

Commits on Feb 2, 2015

• fix circle reference

  zz000

  committed
  c6a5aaf

  Copy full SHA for c6a5aaf

Commits on Jan 15, 2015

• Add Sphinx API docs

  

  Will Daly

  authored and

  wedaly

  committed
  01f3783

  Copy full SHA for 01f3783

Commits on Dec 15, 2014

• Use kafka.util.kafka_bytestring to encode utf-8 when necessary

  

  Dana Powers

  committed
  ed893c3

  Copy full SHA for ed893c3

Commits on Sep 4, 2014

• Update kafka.util.crc32 to unsigned everywhere

  

  Mark Roberts

  committed
  be23042

  Copy full SHA for be23042

Commits on Sep 3, 2014

• Make all unit tests pass on py3.3/3.4

  

  brutasse

  authored and

  Mark Roberts

  committed
  cf0b7f0

  Copy full SHA for cf0b7f0

Commits on Aug 22, 2014

• Fix write_int and write_short type validation

  Show description for 6d6dc17
  mdaniel

  committed
  6d6dc17

  Copy full SHA for 6d6dc17

• PEP8 fixes

  mdaniel

  committed
  bb3827e

  Copy full SHA for bb3827e

Commits on May 7, 2014

• Attempt to fix travis build. Decrease complexity of service.py in favor of in memory logging. Address code review concerns

  wizzat

  committed
  efcf58b

  Copy full SHA for efcf58b

Commits on Apr 25, 2014

• Various fixes

  Show description for 57913f9
  wizzat

  committed
  57913f9

  Copy full SHA for 57913f9

Commits on Oct 4, 2013

• flake8 pass (pep8 and pyflakes)

  mrtheb

  committed
  a03f0c8

  Copy full SHA for a03f0c8

Commits on Oct 3, 2013

• style: remove extra brackets one more time

  

  Vetoshkin Nikita

  authored and

  mumrah

  committed
  e82f04e

  Copy full SHA for e82f04e

• style: fix camelCase variable names

  Show description for 8b05e62
  

  Vetoshkin Nikita

  authored and

  mumrah

  committed
  8b05e62

  Copy full SHA for 8b05e62

• Cherry-pick mrtheb/kafka-python 2b016b69

  Show description for deb584c
  

  mrtheb

  authored and

  mumrah

  committed
  deb584c

  Copy full SHA for deb584c

Commits on Sep 27, 2013

• import bufferunderflow error

  

  Jim Lim

  committed
  f81d254

  Copy full SHA for f81d254

Pagination

Previous

Next