| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | Add BrokerConnection docstring with configuration parameters | Dana Powers | 2016-08-04 | 1 | -0/+65 | |
| | | | ||||||
| | * | Add connection-count to KafkaClient metrics | Dana Powers | 2016-08-04 | 1 | -3/+12 | |
| | | | ||||||
| | * | Add connection-creation-rate / connection-close-rate to KafkaClientMetrics | Dana Powers | 2016-08-04 | 1 | -0/+13 | |
| |/ | ||||||
| * | Fix misspelling of "password" (#793) | Samuel Taylor | 2016-08-04 | 3 | -3/+3 | |
| | | ||||||
| * | Ignore socket.error when checking for protocol out of sync prior to socket ↵ | Dana Powers | 2016-08-03 | 1 | -4/+7 | |
| | | | | | close (#792) | |||||
| * | Support for PLAIN sasl authentication (PR #779) | Dana Powers | 2016-08-03 | 6 | -5/+179 | |
| |\ | | | | | | | Merge squashed branch 'larsjsol-sasl_plain' | |||||
| | * | minor tweaks to get authentication working | Lars Jørgen Solberg | 2016-08-03 | 1 | -8/+7 | |
| | | | ||||||
| | * | Use callbacks for sasl handshake request / response | Dana Powers | 2016-08-03 | 1 | -59/+62 | |
| | | | ||||||
| | * | implement sasl PLAIN mechanism | Lars Jørgen Solberg | 2016-08-03 | 6 | -4/+176 | |
| |/ | ||||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 59 | -0/+121 | |
| | | ||||||
| * | Rename partition_assignment -> assignment in MemberMetadata for consistency | Dana Powers | 2016-08-02 | 1 | -1/+1 | |
| | | ||||||
| * | Clarify api_version=str deprecation warning | Dana Powers | 2016-08-02 | 2 | -2/+2 | |
| | | ||||||
| * | Metadata with_partitions() (#787) | Dana Powers | 2016-08-01 | 1 | -1/+20 | |
| | | | | | add method ClusterMetadata.with_partitions also fixup ClusterMetadata __str__ | |||||
| * | Merge pull request #785 from dpkp/six | Dana Powers | 2016-08-01 | 27 | -30/+902 | |
| |\ | | | | | Vendor python module six; move selectors34 and socketpair under kafka.vendor | |||||
| | * | Vendor six 1.10.0six | Dana Powers | 2016-08-01 | 25 | -27/+899 | |
| | | | ||||||
| | * | Move kafka.socketpair to kafka.vendor.socketpair | Dana Powers | 2016-08-01 | 2 | -1/+1 | |
| | | | ||||||
| | * | Move kafka.selectors34 to kafka.vendor.selectors34 | Dana Powers | 2016-08-01 | 4 | -2/+2 | |
| | | | ||||||
| * | | Fix offset fetch when partitions are manually assigned (#786) | Dana Powers | 2016-08-01 | 1 | -0/+1 | |
| | | | ||||||
| * | | Rename _DEFAULT_CONFIG -> DEFAULT_CONFIG in KafkaProducer (#788) | Dana Powers | 2016-08-01 | 3 | -6/+6 | |
| |/ | | | - also update internal classes RecordAccumulator and Sender | |||||
| * | Use socket_options configuration to setsockopts(). Default TCP_NODELAY (#783) | Dana Powers | 2016-08-01 | 4 | -17/+39 | |
| | | ||||||
| * | Document the ssl_password config option (#780) | Samuel Taylor | 2016-07-26 | 1 | -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_metrics | Dana Powers | 2016-07-26 | 6 | -82/+142 | |
| |\ | | | | | Add client, base coordinator, and a few extra producer metrics. | |||||
| | * | Add KafkaClient metricsmore_metrics | Dana Powers | 2016-07-17 | 2 | -2/+53 | |
| | | | ||||||
| | * | Record produce latency and throttling metrics | Dana Powers | 2016-07-17 | 1 | -4/+9 | |
| | | | ||||||
| | * | Add base coordinator metrics | Dana Powers | 2016-07-17 | 3 | -76/+80 | |
| | | | ||||||
| * | | change pickle_method to use python3 special attributes (#777) | John Win | 2016-07-26 | 1 | -3/+9 | |
| | | | ||||||
| * | | Fix typo in KafkaConsumer documentation (#775) | Samuel Taylor | 2016-07-21 | 1 | -1/+1 | |
| |/ | ||||||
| * | Fix ProduceResponse v2 throttle_time_ms | Dana Powers | 2016-07-17 | 1 | -1/+1 | |
| | | ||||||
| * | Always encode size with MessageSet (#771) | Dana Powers | 2016-07-17 | 2 | -5/+3 | |
| | | ||||||
| * | Catch select errors while capturing test fixture logs | Dana Powers | 2016-07-17 | 1 | -1/+7 | |
| | | ||||||
| * | Avoid buffer overread when compressing messageset in KafkaProducer | Dana Powers | 2016-07-17 | 1 | -1/+2 | |
| | | ||||||
| * | Expand consumer.fetcher comment re comparing request / response offsets | Dana Powers | 2016-07-17 | 1 | -1/+3 | |
| | | ||||||
| * | Delete KafkaConnection class (#769) | Dana Powers | 2016-07-17 | 3 | -398/+2 | |
| | | ||||||
| * | KAFKA-3196: Add checksum and size to RecordMetadata and ConsumerRecord ↵ | Dana Powers | 2016-07-17 | 5 | -19/+38 | |
| | | | | | (#770 / #594) | |||||
| * | Explicit format string argument indices for python 2.6 compatibility | Dana Powers | 2016-07-17 | 3 | -4/+4 | |
| | | ||||||
| * | Simplify RecordMetadata; short circuit callbacks (#768) | Dana Powers | 2016-07-17 | 2 | -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 Powers | 2016-07-17 | 2 | -49/+8 | |
| | | ||||||
| * | KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701) | Dana Powers | 2016-07-17 | 2 | -11/+25 | |
| | | ||||||
| * | KAFKA-2832: Add a consumer config option to exclude internal topics (#765) | Dana Powers | 2016-07-17 | 2 | -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 | |||||
| * | Expose selector type as config option (#764) | Dana Powers | 2016-07-16 | 3 | -3/+15 | |
| | | ||||||
| * | Protect writes to wakeup socket with threading lock (#763 / #709) | Dana Powers | 2016-07-16 | 1 | -2/+6 | |
| | | ||||||
| * | Merge pull request #762 from dpkp/metadata_v1 | Dana Powers | 2016-07-16 | 8 | -52/+154 | |
| |\ | | | | | Use Metadata Request/Response v1 with 0.10+ brokers | |||||
| | * | Use MetadataRequest v1 for 0.10+ api_versionmetadata_v1 | Dana Powers | 2016-07-16 | 2 | -9/+51 | |
| | | | ||||||
| | * | Add rack to BrokerMetadata - it is always None when using MetadataRequest v0 | Dana Powers | 2016-07-16 | 5 | -40/+52 | |
| | | | ||||||
| | * | Add protocol structs for Metadata v1 | Dana Powers | 2016-07-16 | 1 | -4/+36 | |
| | | | ||||||
| | * | Add protocol support for null Arrays | Dana Powers | 2016-07-16 | 1 | -0/+6 | |
| | | | ||||||
| | * | Add Boolean protocol type | Dana Powers | 2016-07-16 | 1 | -0/+10 | |
| | | | ||||||
| * | | Update kafka configuration links -> 0.10.0.0 docs | Dana Powers | 2016-07-16 | 2 | -2/+2 | |
| | | | ||||||
| * | | Merge pull request #754 from dpkp/benchmarks | Dana Powers | 2016-07-16 | 11 | -27/+640 | |
| |\ \ | | | | | | | Producer metrics + consumer/producer benchmark scripts | |||||
| | * | | Adapt benchmark scripts from https://github.com/mrafayaleem/kafka-jythonbenchmarks | Dana Powers | 2016-07-16 | 2 | -0/+337 | |
| | | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |