summaryrefslogtreecommitdiff
path: root/kafka/conn.py
Commit message (Collapse)AuthorAgeFilesLines
...
* Move Request / Response logging from KafkaClient to BrokerConnectionDana Powers2015-12-101-2/+4
| | | | and reenable kafka.conn debug logging in tests
* Add next_correlation_id_recv + send helper methods to BrokerConnectionDana Powers2015-12-091-0/+8
|
* Support requests that do not expect a response in BrokerConnectionDana Powers2015-12-091-2/+3
|
* Exception handling cleanup in BrokerConnection (also catch struct.errors in ↵Dana Powers2015-12-091-4/+4
| | | | recv)
* Add client_id and correlation_id to BrokerConnection constructor kwargsDana Powers2015-12-091-3/+7
|
* Add size and correlation id decoding to try/except block in BrokerConnectionDana Powers2015-12-041-4/+5
|
* BrokerConnection:Dana Powers2015-12-041-11/+65
| | | | | | separate send / recv in BrokerConnection improve connection and error handling use different read and write fds for py3
* Add simple BrokerConnection class; add request.RESPONSE_TYPE class varsDana Powers2015-12-041-0/+36
|
* Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requestsDana Powers2015-12-021-0/+5
|\ | | | | Use unblocking io for broker aware requests
| * Unblocking broker aware requestEnrico Canzonieri2015-11-101-0/+5
| |
* | Support retry semantics in MultiProcessConsumerRoss Duggan2015-09-141-0/+4
|/
* Add a few extra docstring comments about thread-safe clients/connectionsDana Powers2015-06-081-3/+5
|
* Use separate module loggers instead of a single 'kafka' loggerDana Powers2015-06-061-1/+2
|
* Returned original tests, rm dirty flag, name fixesViktor Shlapakov2015-02-251-1/+0
|
* Make KafkaConnection copies usable across threadsAlexey Borzenkov2015-02-251-0/+4
|
* Add Sphinx API docsWill Daly2015-01-151-8/+15
|
* Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-4/+10
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py
| * Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-031-0/+4
| |
| * Make all unit tests pass on py3.3/3.4Bruno Renié2014-09-031-4/+6
| |
* | Minor import cleanupsDana Powers2014-09-041-1/+1
|/
* Add pylint to tox.ini; test both kafka and test; default to error-checking ↵Dana Powers2014-08-251-3/+3
| | | | only; fixup errors; skip kafka/queue.py
* Improve docstrings in kafka.connDana Powers2014-08-191-4/+14
|
* Shutdown socket before closing in kafka.connDana Powers2014-08-191-0/+9
|
* Remove duplicate error handling blocks by moving empty response check into ↵Dana Powers2014-08-191-4/+8
| | | | try block in conn.recv
* Remove self._dirty and check self._sock instead in kafka.connDana Powers2014-08-191-6/+11
|
* socket.sendall should always raise an exception on error; remove extra ↵Dana Powers2014-08-191-6/+7
| | | | return val check in KafkaConnection.send()
* Add some more debug logging to KafkaConnectionDana Powers2014-08-191-0/+7
|
* Initialized _dirty in KafkaConnection __init__() and set _sock to None in ↵Dana Powers2014-08-171-2/+4
| | | | close()
* Call _raise_connection_error in KafkaConnection.reinit() if socket ↵Dana Powers2014-08-171-2/+6
| | | | connection fails
* Support IPv6 hosts and networksAlexey Borzenkov2014-05-091-3/+1
|
* Fix lack of timeout support in KafkaClient and KafkaConnectionmaciejkula2014-04-161-1/+1
|
* Merge branch 'master' into conn_refactorMark Roberts2014-03-181-2/+2
|\
| * Check against basestring instead of str in collect.hosts.Saulius Zemaitaitis2014-03-171-1/+1
| |
| * nit: fixed misspellingZack Dever2014-03-031-1/+1
| |
* | Merge branch 'master' into conn_refactorMark Roberts2014-02-261-1/+27
|\ \ | |/ | | | | | | Conflicts: example.py
| * clean up after comments from @rdiomarmrtheb2014-02-151-3/+5
| |
| * Support list (or comma-separated) of hosts (replaces host and port arguments)mrtheb2014-02-091-1/+4
| |
| * Merge branch 'master' into multihostsmrtheb2014-01-311-48/+45
| |\ | | | | | | | | | | | | | | | | | | | | | | | | Conflicts: kafka/client.py kafka/conn.py setup.py test/test_integration.py test/test_unit.py
| * | Allow KafkaClient to take in a list of brokers for bootstrappingMarc Labbe2013-11-141-7/+26
| | |
* | | Minor refactor in conn.py, update version in __init__.py, add ErrorStringMark Roberts2014-02-251-8/+11
| |/ |/|
* | Merge pull request #107 from rdiomar/fix_default_timeoutsMarc Labbé2014-01-161-1/+7
|\ \ | | | | | | Increase default connection timeout
| * | Change default socket timeout to 120 seconds in both the client and connectionOmar Ghishan2014-01-161-3/+4
| | |
| * | Make the default connection timeout NoneOmar Ghishan2014-01-161-1/+6
| | | | | | | | | | | | This fixes the default behavior, which used to cause a socket timeout when waiting for 10 seconds for a message to be produced.
* | | Merge branch 'repr' of https://github.com/mahendra/kafka-python into ↵mrtheb2014-01-141-1/+1
|\ \ \ | |/ / |/| | | | | | | | | | | | | | | | | mahendra-repr Conflicts: kafka/client.py kafka/consumer.py
| * | Add proper string representations for each classMahendra M2013-10-081-1/+1
| |/
* | remove zero length field name in format string, to work in Python 2.6Vadim Graboys2014-01-131-1/+1
| |
* | Change log.error() back to log.exception()Omar Ghishan2014-01-081-3/+3
| |
* | Change BufferUnderflowError to ConnectionError in conn._read_bytes()Omar Ghishan2014-01-081-3/+2
| | | | | | Both errors are handled the same way when raised and caught, so this makes sense.
* | Remove unnecessary methodOmar Ghishan2014-01-071-17/+8
| |
* | Handle dirty flag in conn.recv()Omar Ghishan2014-01-071-1/+3
| | | | | | | | | | * If the connection is dirty, reinit * If we get a BufferUnderflowError, the server could have gone away, so mark it dirty
View Lorry Controller Status