<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/producer, branch testing</title>
<subtitle>github.com: mumrah/kafka-python.git
</subtitle>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/'/>
<entry>
<title>Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics</title>
<updated>2016-03-13T16:31:18+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-03-13T08:09:03+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=7db5adf1b553ec2d358dad29dc7be676a468fca1'/>
<id>7db5adf1b553ec2d358dad29dc7be676a468fca1</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Add optional timeout parameter to KafkaProducer.flush()</title>
<updated>2016-03-13T16:31:18+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-03-13T07:50:52+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=e4196d5b7ae33fa4fb30706808cf7b437e02f837'/>
<id>e4196d5b7ae33fa4fb30706808cf7b437e02f837</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix for FutureProduceResult.await on python2.6</title>
<updated>2016-03-13T16:31:18+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-03-13T15:48:08+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=afce25267d8423a4fc3aab10ce2edfaa19b7ce44'/>
<id>afce25267d8423a4fc3aab10ce2edfaa19b7ce44</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Update base.py</title>
<updated>2016-02-27T01:37:41+00:00</updated>
<author>
<name>Tom Most</name>
<email>twm@freecog.net</email>
</author>
<published>2016-02-27T01:37:41+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=00d527f480299cc3c0298f3e4699c2f421d3fc64'/>
<id>00d527f480299cc3c0298f3e4699c2f421d3fc64</id>
<content type='text'>
Our app uses `SimpleProducer` and logs lots of these warnings (from line 438):

   producer.stop() called, but producer is not async

This destructor appears to be the cause.

(Also, is it wise to do a thread join from a destructor?)</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Our app uses `SimpleProducer` and logs lots of these warnings (from line 438):

   producer.stop() called, but producer is not async

This destructor appears to be the cause.

(Also, is it wise to do a thread join from a destructor?)</pre>
</div>
</content>
</entry>
<entry>
<title>Catch duplicate batch.done() calls -- this can happen if we maybe_expire then process a response errback</title>
<updated>2016-02-19T06:46:04+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-02-19T06:46:04+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=99bc503b1a549bd0877706ec8f04f7cb35445cda'/>
<id>99bc503b1a549bd0877706ec8f04f7cb35445cda</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Warn if pending batches failed during flush</title>
<updated>2016-02-19T05:54:37+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-02-19T05:54:37+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=642b640404ce034161a1c958fd8e44eece2cec07'/>
<id>642b640404ce034161a1c958fd8e44eece2cec07</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix concurrency bug in RecordAccumulator.ready()</title>
<updated>2016-02-19T05:54:12+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-02-19T05:54:12+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=f2d10f02d3f0bbecff2f9469dc477ccd6046ec59'/>
<id>f2d10f02d3f0bbecff2f9469dc477ccd6046ec59</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Some attributes may not exist in __del__ if we failed assertions</title>
<updated>2016-02-19T05:53:11+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-02-19T05:53:11+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=2dd216b5acafb89d177a79ec779374c5a6f94dcf'/>
<id>2dd216b5acafb89d177a79ec779374c5a6f94dcf</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix bug in SimpleBufferPool memory condition waiting / timeout</title>
<updated>2016-02-19T05:49:37+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-02-19T05:49:37+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=799f53f71275aec7a32c2935837f7c8f3d6283c0'/>
<id>799f53f71275aec7a32c2935837f7c8f3d6283c0</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Merge pull request #558 from dpkp/batch_size_zero</title>
<updated>2016-02-18T16:00:07+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2016-02-18T16:00:07+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=3147dfd64493c12c519104bf4751e00871b2c619'/>
<id>3147dfd64493c12c519104bf4751e00871b2c619</id>
<content type='text'>
Support batch_size = 0 in producer buffers</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Support batch_size = 0 in producer buffers</pre>
</div>
</content>
</entry>
</feed>
