summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Update Sensor time_ms docs; only calculate if neededDana Powers2016-07-161-3/+3
* First stab at public metrics() interface for KafkaConsumer / KafkaProducerDana Powers2016-07-162-2/+31
* Add comment re fetcher stats on compressed topicsDana Powers2016-07-161-0/+2
* Fixup metrics_sample_window_ms docstring in consumerDana Powers2016-07-161-2/+2
* KAFKA-3785: Fetcher spending unnecessary time during metrics recordingDana Powers2016-07-161-2/+4
* Add initial producer-sender metricsDana Powers2016-07-164-13/+250
* Add api_version config to KafkaClient, deprecate str in favor of tuples (#761)Dana Powers2016-07-164-32/+81
* Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706)Dana Powers2016-07-162-20/+25
* Cleanup error logging (#760 / #759)Dana Powers2016-07-152-2/+12
* Bump version for developmentDana Powers2016-07-151-1/+1
* Patch Release 1.2.51.2.5Dana Powers2016-07-151-1/+1
* Add skip_double_compressed_messages option to KafkaConsumerunrecurse_unpack_message_setDana Powers2016-07-142-0/+20
* Log warning if message set appears double-compressed in KafkaConsumerDana Powers2016-07-141-0/+8
* Drop recursion in _unpack_message_setDana Powers2016-07-141-17/+36
* Fix bug causing KafkaProducer to double-compress message batches on retrydouble_compressionDana Powers2016-07-141-16/+23
* Bump version for developmentDana Powers2016-07-101-1/+1
* Patch Release 1.2.41.2.4Dana Powers2016-07-081-1/+1
* Update consumer_timeout_ms docstring per #749Dana Powers2016-07-081-3/+3
* 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 cert...Ashley McKemie2016-07-083-1/+5
* Avoid AttributeErrors in _unregister_cleanup (#747)Dana Powers2016-07-051-1/+1
* Patch Release 1.2.3Dana Powers2016-07-021-1/+1
* Randomize order of topics/partitions processed by fetcher to improve balance ...Dana Powers2016-06-291-0/+4
* allow client.check_version timeout to be set in Producer and Consumer constru...eastlondoner2016-06-292-2/+10
* 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-211-1/+1
* Clarify timeout unit (#734)ms7s2016-06-211-1/+8
* Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733)Dana Powers2016-06-202-30/+47
* check_version should scan nodes until version found or timeout (#731)Dana Powers2016-06-192-17/+46
* Update KafkaClient.least_loaded_node (#730)Dana Powers2016-06-181-23/+17
* Use weakref when registering a producer.close atexit to fix normal gc (#728)Dana Powers2016-06-182-3/+47
* 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
* Bump version for developmentDana Powers2016-06-011-1/+1
* Patch Release 1.2.11.2.1Dana Powers2016-06-011-1/+1
* Fix regression in MessageSet decoding wrt PartialMessages (#716)Dana Powers2016-06-011-3/+6
* Catch response decode errors and log details (#715)Dana Powers2016-06-011-1/+14
* Bump version for developmentDana Powers2016-05-241-1/+1
* Release 1.2.01.2.0Dana Powers2016-05-241-1/+1
* 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 guarant...Dana Powers2016-05-223-11/+33
* Dont use soon-to-be-reserved keyword await as function name (FutureProduceRes...Dana Powers2016-05-222-3/+3
* Fix socket leaks in KafkaClient (#696)Dana Powers2016-05-221-10/+10
* Use standard LZ4 framing for v1 messages / kafka 0.10 (#695)Dana Powers2016-05-224-12/+39
* Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694)Dana Powers2016-05-226-9/+66
* KAFKA-3025: Message v1 -- add timetamp and use relative offset in compressed ...Dana Powers2016-05-227-50/+132
* Always pass encoded message bytes to MessageSet.encode()Dana Powers2016-05-222-40/+22
View Lorry Controller Status