summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Expand)AuthorAgeFilesLines
* Add kafka.serializer interfacesserialize_interfaceDana Powers2016-12-175-24/+67
* Fixup doc references to max_in_flight_requests_per_connectionDana Powers2016-12-173-3/+3
* Fix typo: passowrd --> password (#901)Jeff Widman2016-12-121-1/+1
* Fix possible request draining in ensure_active_group (#896)Dana Powers2016-12-022-12/+16
* DOC: Fix typo 'Defualt' -> 'Default'. (#895)Rolando (Max) Espinoza2016-11-303-3/+3
* When hostname lookup is necessary, do every connect (#812)Evan Bender2016-11-201-5/+9
* Use six.string_types for topic type check in #824Dana Powers2016-11-201-2/+2
* Raise exception if given a bad topic name (#824)Samuel Taylor2016-11-201-0/+7
* Added doc for `max_poll_records` option (#881)Taras Voinarovskyi2016-11-201-1/+2
* setting proper topic value in case if it's empty (#867)Alexander Sibiryakov2016-11-181-11/+4
* Always include an error for logging when the coordinator is marked dead (#890)Dana Powers2016-11-182-9/+9
* Args are optional in BrokerResponseError str (#889)Dana Powers2016-11-181-3/+3
* :wPass timestamp into Message, not just mimic it (#875)Taras Voinarovskyi2016-11-181-2/+6
* Always check for request timeouts (#887)Dana Powers2016-11-182-4/+12
* typo (#883)sharego2016-11-151-1/+1
* Update param in warning (#878)Dana Powers2016-11-141-2/+2
|\
| * Update param in warningJeff Widman2016-11-111-2/+2
* | Remove old design notes from Kafka 8 era (#876)Jeff Widman2016-11-141-32/+0
* | Fix typosJeff Widman2016-11-145-9/+9
|/
* Revert consumer iterators from max_poll_records (#856)Dana Powers2016-10-242-14/+180
* Fix murmur2 bug handling python2 bytes that do not ascii encode (#815)Dana Powers2016-10-222-12/+11
* Bugfix on max_poll_records - TypeError: object of type NoneType has no len()Dana Powers2016-10-041-1/+1
* KAFKA-3007: KafkaConsumer max_poll_records (#831)Dana Powers2016-09-282-240/+120
* Update Partitioners for use with KafkaProducer (#827)barrotsteindev2016-09-283-24/+77
* Monkeypatch max_in_flight_requests_per_connection when checking broker versio...Dana Powers2016-09-281-6/+11
* Fix message timestamp_type (#828)Josh Yudaken2016-09-151-1/+4
* Added ssl_password config option to KafkaProducer class, identical to… (#830)kierkegaard132016-09-152-0/+5
* from kafka import ConsumerRebalanceListener, OffsetAndMetadataDana Powers2016-09-041-1/+2
* Fix quota violation exception message (#809)Dana Powers2016-08-201-4/+4
* Improve KafkaProducer docstring re retries configDana Powers2016-08-201-3/+5
* Add comment for round robin partitioner with different subscriptionsDana Powers2016-08-201-0/+15
* Bump version for developmentDana Powers2016-08-111-1/+1
* Patch Release 1.3.11.3.1Dana Powers2016-08-081-1/+1
* HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on reco...Dana Powers2016-08-081-11/+15
* Bump version for developmentDana Powers2016-08-041-1/+1
* Release 1.3.01.3.0Dana Powers2016-08-041-1/+1
* Drain pending requests to the coordinator before initiating group rejoin (#798)Dana Powers2016-08-041-0/+8
* Send combined size and payload bytes to socket to avoid potentially split pac...Dana Powers2016-08-041-6/+6
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ...Dana Powers2016-08-041-4/+4
* Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metricsDana Powers2016-08-043-8/+17
* Instrument metrics in BrokerConnectionDana Powers2016-08-043-17/+125
* Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-044-14/+13
* Metrics instance must be passed explicitly from KafkaConsumer to KafkaClientDana Powers2016-08-041-1/+1
* Remove unused import from kafka.connDana Powers2016-08-041-1/+1
* Add BrokerConnection docstring with configuration parametersDana Powers2016-08-041-0/+65
* Add connection-count to KafkaClient metricsDana Powers2016-08-041-3/+12
* Add connection-creation-rate / connection-close-rate to KafkaClientMetricsDana Powers2016-08-041-0/+13
* Fix misspelling of "password" (#793)Samuel Taylor2016-08-043-3/+3
* Ignore socket.error when checking for protocol out of sync prior to socket cl...Dana Powers2016-08-031-4/+7
* minor tweaks to get authentication workingLars Jørgen Solberg2016-08-031-8/+7