summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
...
| * Use explicit subscription state flag to handle seek() during message iterationcompacted_offsetsDana Powers2016-07-082-1/+17
| |
| * Fix consumer iteration on compacted topicsDana Powers2016-07-081-1/+1
|/
* Add ssl_password to default_config dicts. Send ssl_password when loading ↵Ashley McKemie2016-07-083-1/+5
| | | | cert chains (#750)
* Push out one more patch for 1.2.3 release1.2.3Dana Powers2016-07-052-0/+2
|
* Avoid AttributeErrors in _unregister_cleanup (#747)Dana Powers2016-07-051-1/+1
|
* Patch Release 1.2.3Dana Powers2016-07-023-1/+21
|
* Randomize order of topics/partitions processed by fetcher to improve balance ↵Dana Powers2016-06-291-0/+4
| | | | (#732)
* allow client.check_version timeout to be set in Producer and Consumer ↵eastlondoner2016-06-293-2/+11
| | | | | constructors (#647) * allow client.check_version timeout to be set in Producer and Consumer constructors
* Wakeup socket optimizations (#740)Dana Powers2016-06-262-2/+7
|
* assert will be disabled by "python -O" (#736)tyronecai2016-06-231-4/+4
|
* Bump version for developmentDana Powers2016-06-211-1/+1
|
* Patch Release 1.2.21.2.2Dana Powers2016-06-213-1/+29
|
* Clarify timeout unit (#734)ms7s2016-06-211-1/+8
|
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-203-32/+147
|
* check_version should scan nodes until version found or timeout (#731)Dana Powers2016-06-192-17/+46
| | | | | * Mute all connection logging during conn.check_version * Always process pending MetadataRequest in conn.check_version * KakfaClient.check_version: Scan all brokers until a version is identified or timeout
* Update KafkaClient.least_loaded_node (#730)Dana Powers2016-06-181-23/+17
| | | | | | - Main node loop should check all known brokers, not just conn objects, which is consistent with the official java client. - This fixes a bug which could cause least_loaded_node to always return the same unavailable node
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-183-3/+61
| | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread
* Close selector when closing the client connection to fix fd leak. (#729)Michael Smith2016-06-171-0/+1
|
* tweak spelling mistake (#719)steve89182016-06-171-1/+1
|
* Rearrange connection tests to separate legacy KafkaConnectionDana Powers2016-06-043-78/+74
|
* Bump version for developmentDana Powers2016-06-011-1/+1
|
* Patch Release 1.2.11.2.1Dana Powers2016-06-013-1/+21
|
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-012-4/+107
|
* Catch response decode errors and log details (#715)Dana Powers2016-06-011-1/+14
|
* Fix Legacy support url (#712)Jonas Gröger2016-06-011-1/+1
|
* Update docs/index.rst re 0.10 broker supportDana Powers2016-05-241-4/+4
|
* Bump version for developmentDana Powers2016-05-241-1/+1
|
* Release 1.2.01.2.0Dana Powers2016-05-241-1/+1
|
* Update changelog for 1.2.0 releaseDana Powers2016-05-242-1/+72
|
* Update README re 0.10 brokersDana Powers2016-05-241-5/+5
|
* Update compatibility for 0.10 kafka releaseDana Powers2016-05-244-6/+6
|
* Add kafka 0.10.0.0 to test listDana Powers2016-05-242-1/+2
|
* Disabling travis deploys -- relying on manual uploads for nowDana Powers2016-05-241-10/+0
|
* KAFKA-3388: Fix expiration of batches sitting in the accumulator (#699)Dana Powers2016-05-221-7/+39
|
* KAFKA-3197: when max.in.flight.request.per.connection = 1, attempt to ↵Dana Powers2016-05-223-11/+33
| | | | guarantee ordering (#698)
* Dont use soon-to-be-reserved keyword await as function name ↵Dana Powers2016-05-222-3/+3
| | | | (FutureProduceResult) (#697)
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-222-13/+16
| | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close()
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-225-12/+62
| | | | | | * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-228-10/+127
|
* Merge pull request #693 from dpkp/message_format_v1Dana Powers2016-05-2212-961/+1188
|\ | | | | Message format v1 (KIP-31 / KIP-32)
| * Add some simple message protocol testsmessage_format_v1Dana Powers2016-05-221-0/+146
| |
| * Rename legacy protocol testsDana Powers2016-05-221-0/+0
| |
| * Improve consumer group test loopDana Powers2016-05-221-13/+13
| |
| * KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ↵Dana Powers2016-05-227-50/+132
| | | | | | | | messagesets
| * Always pass encoded message bytes to MessageSet.encode()Dana Powers2016-05-222-40/+22
| |
| * raise ValueError on protocol encode/decode errorsDana Powers2016-05-221-15/+32
|/
* Add CRL support to SSL support (#683)Vincent Bernat2016-05-194-0/+29
| | | | A user can provide a CRL whose peer certificate will be checked against. This only works with Python 3.4+ and Python 2.7.9+.
* Fixup BrokerConnection check_version strict error checking: 0.9 will fail ↵Dana Powers2016-05-171-0/+7
| | | | with CorrelationIdError
* supplement socket.gaierror exception in BrokerConnection.connect() (#687)Erik Beebe2016-05-171-3/+10
| | | supplement socket.gaierror exception to include the host/port
* kafka/conn: use original hostname for SSL checks (#682)Vincent Bernat2016-05-171-2/+4
| | | | | | | | When the address family is not provided, `self.host` is resolved to one of the IP addresses and replaced by it. The SSL context is then built using `self.host` which is now an IP instead of the proper name. Most of the time, hostname cannot be checked this way. Therefore, save the original hostname in a dedicated property and use this property for the SSL context.
View Lorry Controller Status