| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| | * | Update param in warning | Jeff Widman | 2016-11-11 | 1 | -2/+2 | |
| | | | | | | | In Kafka 9, advertised.host.name was renamed to advertised.listeners | |||||
| * | | Remove old design notes from Kafka 8 era (#876) | Jeff Widman | 2016-11-14 | 1 | -32/+0 | |
| | | | ||||||
| * | | Fix typos (#874) | Dana Powers | 2016-11-14 | 12 | -18/+18 | |
| |\ \ | |/ |/| | ||||||
| | * | Fix typos | Jeff Widman | 2016-11-14 | 12 | -18/+18 | |
| |/ | ||||||
| * | Revert consumer iterators from max_poll_records (#856) | Dana Powers | 2016-10-24 | 2 | -14/+180 | |
| | | ||||||
| * | Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) | Dana Powers | 2016-10-22 | 3 | -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 Powers | 2016-10-04 | 1 | -1/+1 | |
| | | ||||||
| * | KAFKA-3007: KafkaConsumer max_poll_records (#831) | Dana Powers | 2016-09-28 | 5 | -262/+123 | |
| | | ||||||
| * | Update Partitioners for use with KafkaProducer (#827) | barrotsteindev | 2016-09-28 | 5 | -24/+112 | |
| | | ||||||
| * | Monkeypatch max_in_flight_requests_per_connection when checking broker ↵ | Dana Powers | 2016-09-28 | 1 | -6/+11 | |
| | | | | | version (#834) | |||||
| * | Fix message timestamp_type (#828) | Josh Yudaken | 2016-09-15 | 1 | -1/+4 | |
| | | ||||||
| * | Added ssl_password config option to KafkaProducer class, identical to… (#830) | kierkegaard13 | 2016-09-15 | 2 | -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, OffsetAndMetadata | Dana Powers | 2016-09-04 | 1 | -1/+2 | |
| | | ||||||
| * | Fix quota violation exception message (#809) | Dana Powers | 2016-08-20 | 1 | -4/+4 | |
| | | ||||||
| * | Improve KafkaProducer docstring re retries config | Dana Powers | 2016-08-20 | 1 | -3/+5 | |
| | | ||||||
| * | Add comment for round robin partitioner with different subscriptions | Dana Powers | 2016-08-20 | 1 | -0/+15 | |
| | | ||||||
| * | Use 0.10.0.1 for integration tests (#803) | Dana Powers | 2016-08-11 | 6 | -5/+193 | |
| | | | | | | | * Add 0.10.0.1 fixture resources * Use new release 0.10.0.1 for 0.10 testing | |||||
| * | Bump version for development | Dana Powers | 2016-08-11 | 1 | -1/+1 | |
| | | ||||||
| * | Patch Release 1.3.11.3.1 | Dana Powers | 2016-08-08 | 3 | -1/+15 | |
| | | ||||||
| * | HOTFIX: Fix BrokerConnectionMetrics when sensors already exist (i.e., on ↵ | Dana Powers | 2016-08-08 | 1 | -11/+15 | |
| | | | | | reconnects) (#799) | |||||
| * | Bump version for development | Dana Powers | 2016-08-04 | 1 | -1/+1 | |
| | | ||||||
| * | Release 1.3.01.3.0 | Dana Powers | 2016-08-04 | 4 | -2/+120 | |
| | | ||||||
| * | Dump fixture logs on failure | Dana Powers | 2016-08-04 | 1 | -0/+2 | |
| | | ||||||
| * | Drain pending requests to the coordinator before initiating group rejoin (#798) | Dana Powers | 2016-08-04 | 1 | -0/+8 | |
| | | ||||||
| * | Send combined size and payload bytes to socket to avoid potentially split ↵ | Dana Powers | 2016-08-04 | 1 | -6/+6 | |
| | | | | | packets with TCP_NODELAY (#797) | |||||
| * | Merge pull request #796 from dpkp/fixture_auto_ports | Dana Powers | 2016-08-04 | 3 | -32/+27 | |
| |\ | | | | | Fixture auto ports | |||||
| | * | Dont include kafka.vendor in coveragefixture_auto_ports | Dana Powers | 2016-08-04 | 2 | -3/+6 | |
| | | | ||||||
| | * | Try to bind to a new port on fixture failure retries | Dana Powers | 2016-08-04 | 1 | -29/+21 | |
| |/ | ||||||
| * | Change coordinator.needs_join_prepare -> coordinator.rejoining; fix consumer ↵ | Dana Powers | 2016-08-04 | 2 | -5/+10 | |
| | | | | | group test (#795) | |||||
| * | Merge pull request #794 from dpkp/conn_metrics | Dana Powers | 2016-08-04 | 13 | -49/+253 | |
| |\ | | | | | Complete metrics instrumentation | |||||
| | * | Instrument bufferpool-wait-ratio metric in KafkaProducerconn_metrics | Dana Powers | 2016-08-04 | 3 | -8/+17 | |
| | | | ||||||
| | * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 4 | -17/+127 | |
| | | | ||||||
| | * | Treat metric_group_prefix as config in KafkaConsumer | Dana Powers | 2016-08-04 | 6 | -19/+17 | |
| | | | ||||||
| | * | Metrics instance must be passed explicitly from KafkaConsumer to KafkaClient | Dana Powers | 2016-08-04 | 1 | -1/+1 | |
| | | | ||||||
| | * | Remove unused import from kafka.conn | Dana Powers | 2016-08-04 | 1 | -1/+1 | |
| | | | ||||||
| | * | 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 | |
| | | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |