<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka, branch dont-support-api-version-strings</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>Remove support for api versions as strings from KafkaAdmin</title>
<updated>2018-11-18T00:35:46+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-11-17T10:56:55+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=02b9798d23d3566fd8298a4d978d6620489ba263'/>
<id>02b9798d23d3566fd8298a4d978d6620489ba263</id>
<content type='text'>
This is a new class, so let's not support the old version strings and
saddle ourselves with tech debt right from the get-go.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
This is a new class, so let's not support the old version strings and
saddle ourselves with tech debt right from the get-go.
</pre>
</div>
</content>
</entry>
<entry>
<title>Use TypeError for invalid type</title>
<updated>2018-11-17T08:41:24+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-11-13T21:58:51+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=21d68c98470eab6b9e7e5c934017af4a4fd24748'/>
<id>21d68c98470eab6b9e7e5c934017af4a4fd24748</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>raising logging level on messages signalling data loss (#1553)</title>
<updated>2018-11-10T20:46:54+00:00</updated>
<author>
<name>Alexander Sibiryakov</name>
<email>sibiryakov@users.noreply.github.com</email>
</author>
<published>2018-11-10T20:46:54+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=cd47701ba63fc77309066e27b73f50d0150e3e1b'/>
<id>cd47701ba63fc77309066e27b73f50d0150e3e1b</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>set socket timeout for the wake_w (#1577)</title>
<updated>2018-11-10T20:45:51+00:00</updated>
<author>
<name>flaneur</name>
<email>me.ssword@gmail.com</email>
</author>
<published>2018-11-10T20:45:51+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=1c0e8942dc75837a2e43b93e0ed6700fb7752a03'/>
<id>1c0e8942dc75837a2e43b93e0ed6700fb7752a03</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>(Attempt to) Fix deadlock between consumer and heartbeat (#1628)</title>
<updated>2018-11-10T20:45:01+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-11-10T20:45:01+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=0a2ccba3cb1b8636f615a30821123720773a8dfa'/>
<id>0a2ccba3cb1b8636f615a30821123720773a8dfa</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Fix typo</title>
<updated>2018-11-08T03:20:50+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-11-08T03:20:50+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=9d44e3cf8b6a75b11f1087282157aa48eba68a64'/>
<id>9d44e3cf8b6a75b11f1087282157aa48eba68a64</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Pre-compile pack/unpack function calls</title>
<updated>2018-10-29T19:57:42+00:00</updated>
<author>
<name>billyevans</name>
<email>pervushinai@gmail.com</email>
</author>
<published>2018-07-20T21:11:41+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=3689da3d5c02e362d872cf1fb2d65201419c4b93'/>
<id>3689da3d5c02e362d872cf1fb2d65201419c4b93</id>
<content type='text'>
I noticed that pack/unpack functions from
https://github.com/dpkp/kafka-python/blob/master/kafka/protocol/types.py
might be slightly improved. I made pre-compilation for them. It gives
about 10% better performance compared to the current implementation.

Consumption of 100msg:
```
239884    0.187    0.000    0.287    0.000 types.py:18(_unpack) # new version
239884    0.192    0.000    0.323    0.000 types.py:17(_unpack)
```

I also made some profiling for producers/consumers. It gives about
1-1.5% time savings.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
I noticed that pack/unpack functions from
https://github.com/dpkp/kafka-python/blob/master/kafka/protocol/types.py
might be slightly improved. I made pre-compilation for them. It gives
about 10% better performance compared to the current implementation.

Consumption of 100msg:
```
239884    0.187    0.000    0.287    0.000 types.py:18(_unpack) # new version
239884    0.192    0.000    0.323    0.000 types.py:17(_unpack)
```

I also made some profiling for producers/consumers. It gives about
1-1.5% time savings.
</pre>
</div>
</content>
</entry>
<entry>
<title>Document KafkaAdmin class</title>
<updated>2018-10-29T07:56:43+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-10-29T07:45:40+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=4d13713c515796afa535e980b15fa0c2c86ba0eb'/>
<id>4d13713c515796afa535e980b15fa0c2c86ba0eb</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Stop using deprecated log.warn()</title>
<updated>2018-10-27T05:55:52+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-10-27T05:53:03+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=8791f0558fc103df43a2d7ab214904ad9a15f147'/>
<id>8791f0558fc103df43a2d7ab214904ad9a15f147</id>
<content type='text'>
I missed this in my previous cleanup back in 9221fcf83528b5c3657e43636cb84c1d18025acd.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
I missed this in my previous cleanup back in 9221fcf83528b5c3657e43636cb84c1d18025acd.
</pre>
</div>
</content>
</entry>
<entry>
<title>Add temp workaround for upstream pylint bug</title>
<updated>2018-10-27T04:03:48+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-10-26T21:09:54+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=cd0bd8e4db66a532f19a76908c677ebf004f642e'/>
<id>cd0bd8e4db66a532f19a76908c677ebf004f642e</id>
<content type='text'>
Temporarily workaround https://github.com/PyCQA/pylint/issues/2571 so that we can stop pinning `pylint`.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
Temporarily workaround https://github.com/PyCQA/pylint/issues/2571 so that we can stop pinning `pylint`.
</pre>
</div>
</content>
</entry>
</feed>
