<feed xmlns='http://www.w3.org/2005/Atom'>
<title>delta/python-packages/kafka-python.git/kafka/errors.py, branch conn_send_buffer</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 ACL api to KafkaAdminClient (#1833)</title>
<updated>2019-09-28T21:57:05+00:00</updated>
<author>
<name>Ulrik Johansson</name>
<email>ulrik.johansson@gmail.com</email>
</author>
<published>2019-09-28T21:57:05+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=76ad6629350f20acfd6038c1e444a89bcd255f89'/>
<id>76ad6629350f20acfd6038c1e444a89bcd255f89</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Make NotEnoughReplicasError/NotEnoughReplicasAfterAppendError retriable (#1722)</title>
<updated>2019-03-03T20:09:10+00:00</updated>
<author>
<name>le-linh</name>
<email>48096349+le-linh@users.noreply.github.com</email>
</author>
<published>2019-03-03T20:09:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=940b1c5582294ecc29ad308afbcebd605f3ab009'/>
<id>940b1c5582294ecc29ad308afbcebd605f3ab009</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 broker-errors for client-side problems</title>
<updated>2018-11-18T08:20:55+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-11-17T09:37:15+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=f3105a434f3bd2fb3f8899e4861e187e786b03da'/>
<id>f3105a434f3bd2fb3f8899e4861e187e786b03da</id>
<content type='text'>
`UnsupportedVersionError` is intended to indicate a server-side error:
https://github.com/dpkp/kafka-python/blob/ba7372e44ffa1ee49fb4d5efbd67534393e944db/kafka/errors.py#L375-L378

So we should not be raising it for client-side errors. I realize that
semantically this seems like the appropriate error to raise. However,
this is confusing when debugging... for a real-life example, see
https://github.com/Parsely/pykafka/issues/697. So I strongly feel that
server-side errors should be kept separate from client-side errors,
even if all the client is doing is proactively protecting against
hitting a situation where the broker would return this error.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
`UnsupportedVersionError` is intended to indicate a server-side error:
https://github.com/dpkp/kafka-python/blob/ba7372e44ffa1ee49fb4d5efbd67534393e944db/kafka/errors.py#L375-L378

So we should not be raising it for client-side errors. I realize that
semantically this seems like the appropriate error to raise. However,
this is confusing when debugging... for a real-life example, see
https://github.com/Parsely/pykafka/issues/697. So I strongly feel that
server-side errors should be kept separate from client-side errors,
even if all the client is doing is proactively protecting against
hitting a situation where the broker would return this error.
</pre>
</div>
</content>
</entry>
<entry>
<title>Remove ConsumerTimeout</title>
<updated>2018-09-27T17:01:54+00:00</updated>
<author>
<name>Jonathan Emord</name>
<email>emord@users.noreply.github.com</email>
</author>
<published>2018-09-08T18:06:42+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ba7372e44ffa1ee49fb4d5efbd67534393e944db'/>
<id>ba7372e44ffa1ee49fb4d5efbd67534393e944db</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Retain but deprecate kafka.errors.ConnectionError for compatibility</title>
<updated>2018-05-26T18:54:33+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-05-26T18:54:33+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=535d8f6a85969c4e07de0bc81e14513c677995be'/>
<id>535d8f6a85969c4e07de0bc81e14513c677995be</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Ignore MetadataResponses with empty broker list (#1506)</title>
<updated>2018-05-26T15:43:25+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2018-05-26T15:43:25+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ee26c3f547f357d639b421b3e38a74e87e21f346'/>
<id>ee26c3f547f357d639b421b3e38a74e87e21f346</id>
<content type='text'>

</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>

</pre>
</div>
</content>
</entry>
<entry>
<title>Stop shadowing `ConnectionError`</title>
<updated>2018-05-23T22:19:01+00:00</updated>
<author>
<name>Jeff Widman</name>
<email>jeff@jeffwidman.com</email>
</author>
<published>2018-05-10T23:12:19+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=11cf3973bfc64ab0b4e471fc56dae911df1ec8d9'/>
<id>11cf3973bfc64ab0b4e471fc56dae911df1ec8d9</id>
<content type='text'>
In Python3, `ConnectionError` is a native exception. So rename our
custom one to `KafkaConnectionError` to prevent accidentally
shadowing the native one.

Note that there are still valid uses of `ConnectionError` in this code.
They already expect a native Python3 `ConnectionError`, and also already
handle the Python2 compatibility issues.
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
In Python3, `ConnectionError` is a native exception. So rename our
custom one to `KafkaConnectionError` to prevent accidentally
shadowing the native one.

Note that there are still valid uses of `ConnectionError` in this code.
They already expect a native Python3 `ConnectionError`, and also already
handle the Python2 compatibility issues.
</pre>
</div>
</content>
</entry>
<entry>
<title>KAFKA-3888 Use background thread to process consumer heartbeats (#1266)</title>
<updated>2017-12-21T22:46:10+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2017-12-21T22:46:10+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=ad024d1e897dbf16bd629fa63895bd7af4a8d959'/>
<id>ad024d1e897dbf16bd629fa63895bd7af4a8d959</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Refactor MessageSet and Message into LegacyRecordBatch to later support v2 message format</title>
<updated>2017-10-11T15:09:17+00:00</updated>
<author>
<name>Taras</name>
<email>voyn1991@gmail.com</email>
</author>
<published>2017-10-09T21:13:16+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=fbea5f04bccd28f3aa15a1711548b131504591ac'/>
<id>fbea5f04bccd28f3aa15a1711548b131504591ac</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
<entry>
<title>Add kafka.protocol.parser.KafkaProtocol w/ receive and send (#1230)</title>
<updated>2017-10-10T17:15:40+00:00</updated>
<author>
<name>Dana Powers</name>
<email>dana.powers@gmail.com</email>
</author>
<published>2017-10-10T17:15:40+00:00</published>
<link rel='alternate' type='text/html' href='http://git.baserock.org/cgit/delta/python-packages/kafka-python.git/commit/?id=0d4e28f05efd2a1e39558ab2516e054b97297900'/>
<id>0d4e28f05efd2a1e39558ab2516e054b97297900</id>
<content type='text'>
</content>
<content type='xhtml'>
<div xmlns='http://www.w3.org/1999/xhtml'>
<pre>
</pre>
</div>
</content>
</entry>
</feed>
