| Commit message (Collapse) | Author | Age | Files | Lines | |
|---|---|---|---|---|---|
| * | Merge pull request #473 from ecanzonieri/use_unblocking_io_for_aware_requests | Dana Powers | 2015-12-02 | 1 | -0/+5 |
| |\ | | | | | Use unblocking io for broker aware requests | ||||
| | * | Unblocking broker aware request | Enrico Canzonieri | 2015-11-10 | 1 | -0/+5 |
| | | | |||||
| * | | Support retry semantics in MultiProcessConsumer | Ross Duggan | 2015-09-14 | 1 | -0/+4 |
| |/ | |||||
| * | Add a few extra docstring comments about thread-safe clients/connections | Dana Powers | 2015-06-08 | 1 | -3/+5 |
| | | |||||
| * | Use separate module loggers instead of a single 'kafka' logger | Dana Powers | 2015-06-06 | 1 | -1/+2 |
| | | |||||
| * | Returned original tests, rm dirty flag, name fixes | Viktor Shlapakov | 2015-02-25 | 1 | -1/+0 |
| | | |||||
| * | Make KafkaConnection copies usable across threads | Alexey Borzenkov | 2015-02-25 | 1 | -0/+4 |
| | | |||||
| * | Add Sphinx API docs | Will Daly | 2015-01-15 | 1 | -8/+15 |
| | | |||||
| * | Merge pull request #227 from wizzat-feature/py3 | Dana Powers | 2014-09-07 | 1 | -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 remaining | Bruno Renié | 2014-09-03 | 1 | -0/+4 |
| | | | |||||
| | * | Make all unit tests pass on py3.3/3.4 | Bruno Renié | 2014-09-03 | 1 | -4/+6 |
| | | | |||||
| * | | Minor import cleanups | Dana Powers | 2014-09-04 | 1 | -1/+1 |
| |/ | |||||
| * | Add pylint to tox.ini; test both kafka and test; default to error-checking ↵ | Dana Powers | 2014-08-25 | 1 | -3/+3 |
| | | | | | only; fixup errors; skip kafka/queue.py | ||||
| * | Improve docstrings in kafka.conn | Dana Powers | 2014-08-19 | 1 | -4/+14 |
| | | |||||
| * | Shutdown socket before closing in kafka.conn | Dana Powers | 2014-08-19 | 1 | -0/+9 |
| | | |||||
| * | Remove duplicate error handling blocks by moving empty response check into ↵ | Dana Powers | 2014-08-19 | 1 | -4/+8 |
| | | | | | try block in conn.recv | ||||
| * | Remove self._dirty and check self._sock instead in kafka.conn | Dana Powers | 2014-08-19 | 1 | -6/+11 |
| | | |||||
| * | socket.sendall should always raise an exception on error; remove extra ↵ | Dana Powers | 2014-08-19 | 1 | -6/+7 |
| | | | | | return val check in KafkaConnection.send() | ||||
| * | Add some more debug logging to KafkaConnection | Dana Powers | 2014-08-19 | 1 | -0/+7 |
| | | |||||
| * | Initialized _dirty in KafkaConnection __init__() and set _sock to None in ↵ | Dana Powers | 2014-08-17 | 1 | -2/+4 |
| | | | | | close() | ||||
| * | Call _raise_connection_error in KafkaConnection.reinit() if socket ↵ | Dana Powers | 2014-08-17 | 1 | -2/+6 |
| | | | | | connection fails | ||||
| * | Support IPv6 hosts and networks | Alexey Borzenkov | 2014-05-09 | 1 | -3/+1 |
| | | |||||
| * | Fix lack of timeout support in KafkaClient and KafkaConnection | maciejkula | 2014-04-16 | 1 | -1/+1 |
| | | |||||
| * | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-03-18 | 1 | -2/+2 |
| |\ | |||||
| | * | Check against basestring instead of str in collect.hosts. | Saulius Zemaitaitis | 2014-03-17 | 1 | -1/+1 |
| | | | |||||
| | * | nit: fixed misspelling | Zack Dever | 2014-03-03 | 1 | -1/+1 |
| | | | |||||
| * | | Merge branch 'master' into conn_refactor | Mark Roberts | 2014-02-26 | 1 | -1/+27 |
| |\ \ | |/ | | | | | | | Conflicts: example.py | ||||
| | * | clean up after comments from @rdiomar | mrtheb | 2014-02-15 | 1 | -3/+5 |
| | | | |||||
| | * | Support list (or comma-separated) of hosts (replaces host and port arguments) | mrtheb | 2014-02-09 | 1 | -1/+4 |
| | | | |||||
| | * | Merge branch 'master' into multihosts | mrtheb | 2014-01-31 | 1 | -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 bootstrapping | Marc Labbe | 2013-11-14 | 1 | -7/+26 |
| | | | | |||||
| * | | | Minor refactor in conn.py, update version in __init__.py, add ErrorString | Mark Roberts | 2014-02-25 | 1 | -8/+11 |
| | |/ |/| | |||||
| * | | Merge pull request #107 from rdiomar/fix_default_timeouts | Marc Labbé | 2014-01-16 | 1 | -1/+7 |
| |\ \ | | | | | | | Increase default connection timeout | ||||
| | * | | Change default socket timeout to 120 seconds in both the client and connection | Omar Ghishan | 2014-01-16 | 1 | -3/+4 |
| | | | | |||||
| | * | | Make the default connection timeout None | Omar Ghishan | 2014-01-16 | 1 | -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 ↵ | mrtheb | 2014-01-14 | 1 | -1/+1 |
| |\ \ \ | |/ / |/| | | | | | | | | | | | | | | | | | mahendra-repr Conflicts: kafka/client.py kafka/consumer.py | ||||
| | * | | Add proper string representations for each class | Mahendra M | 2013-10-08 | 1 | -1/+1 |
| | |/ | |||||
| * | | remove zero length field name in format string, to work in Python 2.6 | Vadim Graboys | 2014-01-13 | 1 | -1/+1 |
| | | | |||||
| * | | Change log.error() back to log.exception() | Omar Ghishan | 2014-01-08 | 1 | -3/+3 |
| | | | |||||
| * | | Change BufferUnderflowError to ConnectionError in conn._read_bytes() | Omar Ghishan | 2014-01-08 | 1 | -3/+2 |
| | | | | | | | Both errors are handled the same way when raised and caught, so this makes sense. | ||||
| * | | Remove unnecessary method | Omar Ghishan | 2014-01-07 | 1 | -17/+8 |
| | | | |||||
| * | | Handle dirty flag in conn.recv() | Omar Ghishan | 2014-01-07 | 1 | -1/+3 |
| | | | | | | | | | | | * If the connection is dirty, reinit * If we get a BufferUnderflowError, the server could have gone away, so mark it dirty | ||||
| * | | Use the same timeout when reinitializing a connection | Omar Ghishan | 2014-01-07 | 1 | -2/+3 |
| | | | |||||
| * | | Raise a ConnectionError when a socket.error is raised when receiving data | Omar Ghishan | 2014-01-06 | 1 | -7/+11 |
| | | | | | | | | | Also, log.exception() is unhelpfully noisy. Use log.error() with some error details in the message instead. | ||||
| * | | * Guarantee reading the expected number of bytes from the socket every time | Omar Ghishan | 2014-01-06 | 1 | -26/+22 |
| | | | | | | | | | | | | | | | | | | | | | | | | | * Remove bufsize from client and conn, since they're not actually enforced Notes: This commit changes behavior a bit by raising a BufferUnderflowError when no data is received for the message size rather than a ConnectionError. Since bufsize in the socket is not actually enforced, but it is used by the consumer when creating requests, moving it there until a better solution is implemented. | ||||
| * | | Read the correct number of bytes from kafka. | Omar Ghishan | 2014-01-06 | 1 | -3/+2 |
| | | | | | | | | | | | | | According to the protocol documentation, the 4 byte integer at the beginning of a response represents the size of the payload only, not including those bytes. See http://goo.gl/rg5uom | ||||
| * | | Allow customizing socket timeouts. | Omar Ghishan | 2014-01-06 | 1 | -2/+2 |
| | | | | | | | | | | | | | Previously, if you try to consume a message with a timeout greater than 10 seconds, but you don't receive data in those 10 seconds, a socket.timeout exception is raised. This allows a higher socket timeout to be set, or even None for no timeout. | ||||
| * | | reduce memory copies when consuming kafka responses | Evan Klitzke | 2013-12-25 | 1 | -5/+2 |
| |/ | |||||
| * | Merge branch 'master' into prod-windows | Mahendra M | 2013-10-08 | 1 | -10/+18 |
| |\ | | | | | | | | | Conflicts: kafka/producer.py | ||||
| | * | make changes to be more fault tolerant: clean up connections, brokers, ↵ | Jim Lim | 2013-10-04 | 1 | -10/+18 |
| | | | | | | | | | | | | | | | | | failed_messages - add integration tests for sync producer - add integration tests for async producer w. leadership election - use log.exception | ||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |