Vendor six 1.10.02016-08-01T21:47:40+00:00Dana Powersdana.powers@gmail.com2016-08-01T16:45:39+00:0051b3d311f3930d9bb86877ca235156eb9d46763c
Use weakref when registering a producer.close atexit to fix normal gc (#728)2016-06-18T21:51:23+00:00Dana Powersdana.powers@gmail.com2016-06-18T21:51:23+00:006271c02c6eebf52a6d368416db49bfa57b09ef04
* Use weakref when registering a producer.close atexit to fix normal gc
* Test that del(producer) terminates async thread
* Use weakref when registering a producer.close atexit to fix normal gc
* Test that del(producer) terminates async thread
Update imports from kafka.common -> kafka.errors / kafka.structs2016-04-05T16:35:45+00:00Dana Powersdana.powers@gmail.com2016-04-05T16:34:48+00:005a14bd8c947251d1a8f848175cc3cf2b07af3411
break up some circular references and close client wake pipe on __del__2016-02-17T05:30:38+00:00aischme+bosch@aitmp.com2016-02-17T05:30:38+00:00d7522b0fb79bffbe10a2548658a48829dd1a5c33
Drop kafka_bytestring2015-12-11T02:37:03+00:00Dana Powersdana.powers@rd.io2015-12-11T00:24:32+00:00d54980a2cd918f243e30ecc23a588fb597957e41
Switch crc32 back to signed integer -- this is consistent with protocol encoding spec2015-12-04T19:25:39+00:00Dana Powersdana.powers@rd.io2015-11-28T11:34:37+00:00f08775a6198cd16a7bc9ec93ffd057f65064ec54
Raise an error if we attempt to group duplicate topic-partition payloads2015-06-06T23:14:49+00:00Dana Powersdana.powers@rd.io2015-06-06T23:08:01+00:00868115c703afc4403adc8d9481bf31d2c15064dd
- previously this would simply drop one of the payloads
- previously this would simply drop one of the payloads
Stopping daemonized threads when references to these threads are lost2015-03-02T22:49:08+00:00Christophe-Marie Duquesnechmd@chmd.fr2015-02-16T23:50:51+00:0004979248afa82af77d02f76fbf12456bb83ae334
Fix python2.6 threading.Event bug in ReentrantTimer2015-02-03T19:35:51+00:00Dana Powersdana.powers@rd.io2015-02-03T19:35:51+00:00a21f701e1e794b21c307df4d4391f3600917bc66