summaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* Args are optional in BrokerResponseError strkafka_error_strDana Powers2016-11-181-3/+3
|
* 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-223-27/+20
| | | | | | * Add test for murmur2 py2 bytes bug * Fix murmur2 handling of python2 bytes * Drop bytearray / str / unicode MurmurPartitioner tests -- no longer supported * Make DefaultPartitioner importable from kafka.partitioner
* 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-285-262/+123
|
* Update Partitioners for use with KafkaProducer (#827)barrotsteindev2016-09-285-24/+112
|
* Monkeypatch max_in_flight_requests_per_connection when checking broker ↵Dana Powers2016-09-281-6/+11
| | | | version (#834)
* 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
| | | | | | | | * Added ssl_password config option to KafkaProducer class, identical to option in KafkaConsumer class * removed non-ascii characters * changed - to : in comments
* 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
|
* Use 0.10.0.1 for integration tests (#803)Dana Powers2016-08-116-5/+193
| | | | | | * Add 0.10.0.1 fixture resources * Use new release 0.10.0.1 for 0.10 testing
* Bump version for developmentDana Powers2016-08-111-1/+1
|
* Patch Release 1.3.11.3.1Dana Powers2016-08-083-1/+15
|
* HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on ↵Dana Powers2016-08-081-11/+15
| | | | reconnects) (#799)
* Bump version for developmentDana Powers2016-08-041-1/+1
|
* Release 1.3.01.3.0Dana Powers2016-08-044-2/+120
|
* Dump fixture logs on failureDana Powers2016-08-041-0/+2
|
* 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 ↵Dana Powers2016-08-041-6/+6
| | | | packets with TCP_NODELAY (#797)
* Merge pull request #796 from dpkp/fixture_auto_portsDana Powers2016-08-043-32/+27
|\ | | | | Fixture auto ports
| * Dont include kafka.vendor in coveragefixture_auto_portsDana Powers2016-08-042-3/+6
| |
| * Try to bind to a new port on fixture failure retriesDana Powers2016-08-041-29/+21
|/
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ↵Dana Powers2016-08-042-5/+10
| | | | group test (#795)
* Merge pull request #794 from dpkp/conn_metricsDana Powers2016-08-0413-49/+253
|\ | | | | Complete metrics instrumentation
| * Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metricsDana Powers2016-08-043-8/+17
| |
| * Instrument metrics in BrokerConnectionDana Powers2016-08-044-17/+127
| |
| * Treat metric_group_prefix as config in KafkaConsumerDana Powers2016-08-046-19/+17
| |
| * 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 ↵Dana Powers2016-08-031-4/+7
| | | | close (#792)
* Support for PLAIN sasl authentication (PR #779)Dana Powers2016-08-036-5/+179
|\ | | | | | | Merge squashed branch 'larsjsol-sasl_plain'
| * minor tweaks to get authentication workingLars Jørgen Solberg2016-08-031-8/+7
| |
| * Use callbacks for sasl handshake request / responseDana Powers2016-08-031-59/+62
| |
| * implement sasl PLAIN mechanismLars Jørgen Solberg2016-08-036-4/+176
|/
* Always absolute_importabsolute_importDana Powers2016-08-0259-0/+121
|
* Rename partition_assignment -> assignment in MemberMetadata for consistencyDana Powers2016-08-021-1/+1
|
* Clarify api_version=str deprecation warningDana Powers2016-08-022-2/+2
|
* Metadata with_partitions() (#787)Dana Powers2016-08-011-1/+20
| | | | add method ClusterMetadata.with_partitions also fixup ClusterMetadata __str__
* Merge pull request #785 from dpkp/sixDana Powers2016-08-0127-30/+902
|\ | | | | Vendor python module six; move selectors34 and socketpair under kafka.vendor
| * Vendor six 1.10.0sixDana Powers2016-08-0125-27/+899
| |
| * Move kafka.socketpair to kafka.vendor.socketpairDana Powers2016-08-012-1/+1
| |
| * Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-014-2/+2
| |
* | Fix offset fetch when partitions are manually assigned (#786)Dana Powers2016-08-011-0/+1
| |
View Lorry Controller Status