summaryrefslogtreecommitdiff
path: root/kafka
Commit message (Collapse)AuthorAgeFilesLines
...
* 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 ↵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-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 ↵Dana Powers2016-08-041-6/+6
| | | | packets with TCP_NODELAY (#797)
* Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ↵Dana Powers2016-08-041-4/+4
| | | | group test (#795)
* 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 ↵Dana Powers2016-08-031-4/+7
| | | | close (#792)
* 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-0255-0/+113
|
* 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-0124-27/+901
|\ | | | | Vendor python module six; move selectors34 and socketpair under kafka.vendor
| * Vendor six 1.10.0sixDana Powers2016-08-0123-25/+899
| |
| * Move kafka.socketpair to kafka.vendor.socketpairDana Powers2016-08-012-1/+1
| |
| * Move kafka.selectors34 to kafka.vendor.selectors34Dana Powers2016-08-013-1/+1
| |
* | Fix offset fetch when partitions are manually assigned (#786)Dana Powers2016-08-011-0/+1
| |
* | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788)Dana Powers2016-08-013-6/+6
|/ | | - also update internal classes RecordAccumulator and Sender
* Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783)Dana Powers2016-08-014-17/+39
|
* Document the ssl_password config option (#780)Samuel Taylor2016-07-261-0/+2
| | | | PR #750 added the code for passing along a password, but not any documentation on it
* Merge pull request #772 from dpkp/more_metricsDana Powers2016-07-266-82/+142
|\ | | | | Add client, base coordinator, and a few extra producer metrics.
| * Add KafkaClient metricsmore_metricsDana Powers2016-07-172-2/+53
| |
| * Record produce latency and throttling metricsDana Powers2016-07-171-4/+9
| |
| * Add base coordinator metricsDana Powers2016-07-173-76/+80
| |
* | change pickle_method to use python3 special attributes (#777)John Win2016-07-261-3/+9
| |
* | Fix typo in KafkaConsumer documentation (#775)Samuel Taylor2016-07-211-1/+1
|/
* Fix ProduceResponse v2 throttle_time_msDana Powers2016-07-171-1/+1
|
* Always encode size with MessageSet (#771)Dana Powers2016-07-171-3/+1
|
* Avoid buffer overread when compressing messageset in KafkaProducerDana Powers2016-07-171-1/+2
|
* Expand consumer.fetcher comment re comparing request / response offsetsDana Powers2016-07-171-1/+3
|
* Delete KafkaConnection class (#769)Dana Powers2016-07-172-188/+2
|
* KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵Dana Powers2016-07-175-19/+38
| | | | (#770 / #594)
* Explicit format string argument indices for python 2.6 compatibilityDana Powers2016-07-173-4/+4
|
* Simplify RecordMetadata; short circuit callbacks (#768)Dana Powers2016-07-172-20/+9
| | | | Simplify RecordMetadata to unaltered namedtuple -- minor speed optimization Minor optimization: inline check for no callbacks
* KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626)Dana Powers2016-07-171-44/+8
|
* KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701)Dana Powers2016-07-171-10/+24
|
* KAFKA-2832: Add a consumer config option to exclude internal topics (#765)Dana Powers2016-07-172-4/+13
| | | | Use exclude_internal_topics config in KafkaConsumer to avoid subscribe patterns matching internal topics Raise error during rebalance if subscribed topics are not authorized
View Lorry Controller Status