| Commit message (Collapse) | Author | Age | Files | Lines | ||
|---|---|---|---|---|---|---|
| ... | ||||||
| * | Update pytest fixtures to new yield syntax (#919) | Jeff Widman | 2017-01-11 | 2 | -10/+6 | |
| | | ||||||
| * | Add metadata update to pattern subscribing (#915) | Dmitry Lazurkin | 2016-12-27 | 1 | -2/+26 | |
| | | ||||||
| * | When hostname lookup is necessary, do every connect (#812) | Evan Bender | 2016-11-20 | 1 | -0/+28 | |
| | | | | | | Fixes a bug where lookup was done only once for the whole life of the process -- if a broker's IP changed, client couldn't reconnect. | |||||
| * | Fix typos | Jeff Widman | 2016-11-14 | 3 | -3/+3 | |
| | | ||||||
| * | Fix murmur2 bug handling python2 bytes that do not ascii encode (#815) | Dana Powers | 2016-10-22 | 1 | -15/+9 | |
| | | | | | | | * 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 | |||||
| * | KAFKA-3007: KafkaConsumer max_poll_records (#831) | Dana Powers | 2016-09-28 | 3 | -22/+3 | |
| | | ||||||
| * | Update Partitioners for use with KafkaProducer (#827) | barrotsteindev | 2016-09-28 | 1 | -0/+33 | |
| | | ||||||
| * | Dump fixture logs on failure | Dana Powers | 2016-08-04 | 1 | -0/+2 | |
| | | ||||||
| * | 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 | 1 | -1/+6 | |
| | | | | | group test (#795) | |||||
| * | Instrument metrics in BrokerConnection | Dana Powers | 2016-08-04 | 1 | -0/+2 | |
| | | ||||||
| * | Treat metric_group_prefix as config in KafkaConsumer | Dana Powers | 2016-08-04 | 2 | -5/+4 | |
| | | ||||||
| * | Always absolute_importabsolute_import | Dana Powers | 2016-08-02 | 4 | -0/+8 | |
| | | ||||||
| * | Move kafka.selectors34 to kafka.vendor.selectors34 | Dana Powers | 2016-08-01 | 1 | -1/+1 | |
| | | ||||||
| * | Always encode size with MessageSet (#771) | Dana Powers | 2016-07-17 | 1 | -2/+2 | |
| | | ||||||
| * | Catch select errors while capturing test fixture logs | Dana Powers | 2016-07-17 | 1 | -1/+7 | |
| | | ||||||
| * | Delete KafkaConnection class (#769) | Dana Powers | 2016-07-17 | 1 | -210/+0 | |
| | | ||||||
| * | KAFKA-3486: fix autocommit when partitions assigned manually (#767 / #626) | Dana Powers | 2016-07-17 | 1 | -5/+0 | |
| | | ||||||
| * | KAFKA-3117: handle metadata updates during consumer rebalance (#766 / #701) | Dana Powers | 2016-07-17 | 1 | -1/+1 | |
| | | ||||||
| * | Merge pull request #762 from dpkp/metadata_v1 | Dana Powers | 2016-07-16 | 2 | -28/+37 | |
| |\ | | | | | Use Metadata Request/Response v1 with 0.10+ brokers | |||||
| | * | Add rack to BrokerMetadata - it is always None when using MetadataRequest v0 | Dana Powers | 2016-07-16 | 2 | -28/+37 | |
| | | | ||||||
| * | | Add initial producer-sender metrics | Dana Powers | 2016-07-16 | 1 | -5/+11 | |
| |/ | ||||||
| * | Add api_version config to KafkaClient, deprecate str in favor of tuples (#761) | Dana Powers | 2016-07-16 | 5 | -108/+65 | |
| | | ||||||
| * | Include zk-offset configuration in coordinator unit tests | Dana Powers | 2016-07-16 | 1 | -2/+6 | |
| | | ||||||
| * | Fix KafkaConsumer autocommit for 0.8 brokers (#756 / #706) | Dana Powers | 2016-07-16 | 1 | -3/+2 | |
| | | | | | * Dont wait for group join to enable AutoCommitTask if broker version < 0.9 * For zookeeper offset storage, set a "coordinator" with least_loaded_node | |||||
| * | Test MessageSetBuffer close -- cover double close compression bug | Dana Powers | 2016-07-14 | 1 | -0/+70 | |
| | | ||||||
| * | Avoid busy poll during metadata refresh failure with retry_backoff_ms (#733) | Dana Powers | 2016-06-20 | 1 | -2/+100 | |
| | | ||||||
| * | Use weakref when registering a producer.close atexit to fix normal gc (#728) | Dana Powers | 2016-06-18 | 1 | -0/+14 | |
| | | | | | * Use weakref when registering a producer.close atexit to fix normal gc * Test that del(producer) terminates async thread | |||||
| * | Rearrange connection tests to separate legacy KafkaConnection | Dana Powers | 2016-06-04 | 3 | -78/+74 | |
| | | ||||||
| * | Fix regression in MessageSet decoding wrt PartialMessages (#716) | Dana Powers | 2016-06-01 | 1 | -1/+101 | |
| | | ||||||
| * | Fix socket leaks in KafkaClient (#696) | Dana Powers | 2016-05-22 | 1 | -3/+6 | |
| | | | | | | * Cleanup wakeup socketpair on close to avoid leak in KafkaClient * Cleanup unneeded bootstrap connection to avoid leak in KafkaClient * Dont warn on socket disconnections caused by KafkaClient.close() | |||||
| * | Use standard LZ4 framing for v1 messages / kafka 0.10 (#695) | Dana Powers | 2016-05-22 | 1 | -0/+23 | |
| | | | | | | | * LZ4 framing fixed in 0.10 / message v1 -- retain broken lz4 code for compatibility * lz4f does not support easy incremental decompression - raise RuntimeError * Update lz4 codec tests | |||||
| * | Use Fetch/Produce API v2 for brokers >= 0.10 (uses message format v1) (#694) | Dana Powers | 2016-05-22 | 2 | -1/+61 | |
| | | ||||||
| * | Add some simple message protocol testsmessage_format_v1 | Dana Powers | 2016-05-22 | 1 | -0/+146 | |
| | | ||||||
| * | Rename legacy protocol tests | Dana Powers | 2016-05-22 | 1 | -0/+0 | |
| | | ||||||
| * | Improve consumer group test loop | Dana Powers | 2016-05-22 | 1 | -13/+13 | |
| | | ||||||
| * | * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages* ↵ | Paul Cavallaro | 2016-05-10 | 1 | -1/+18 | |
| | | | | | | [Legacy Protocol] Update legacy protocol to handle compressed messages * [SimpleConsumer] Fix legacy SimpleConsumer when using compressed messages | |||||
| * | Add disconnected socket tests for conn.recv() | Dana Powers | 2016-04-25 | 1 | -1/+46 | |
| | | ||||||
| * | Rename mocked socket as _socket in test_conn | Dana Powers | 2016-04-25 | 1 | -18/+16 | |
| | | ||||||
| * | Merge pull request #670 from zackdever/predictable-future | Dana Powers | 2016-04-25 | 2 | -1/+4 | |
| |\ | | | | | Consistent error handling in future call/errbacks + better test failures | |||||
| | * | enable errors on callbacks in testing. fix broken test. | Zack Dever | 2016-04-25 | 2 | -1/+4 | |
| | | | ||||||
| * | | Allow setting host interface in KafkaFixture.instance | Dana Powers | 2016-04-25 | 1 | -2/+4 | |
| |/ | ||||||
| * | More thorough IPv6 support that uses getaddrinfo to resolve names | James Brown | 2016-04-24 | 4 | -19/+38 | |
| | | | | | Fixes #641 | |||||
| * | instrument metrics for fetch requests | Zack Dever | 2016-04-13 | 1 | -1/+2 | |
| | | ||||||
| * | Beginnings of metrics instrumentation in kafka consumer. | Zack Dever | 2016-04-13 | 1 | -6/+13 | |
| | | | | | | | This adds the parent metrics instance to kafka consumer, which will eventually be used to instrument everything under consumer. To start I ported the java consumer coordinator metrics. | |||||
| * | Basic dictionary reporter in place of the java JMX reporter. | Zack Dever | 2016-04-13 | 1 | -3/+36 | |
| | | ||||||
| * | Kafka metrics java port. No reporters or instrumentation. | Zack Dever | 2016-04-13 | 1 | -0/+466 | |
| | | | | | | There is no straight translation for the JMX reporter into python, so I'll do something else in a separate commit. | |||||
| * | Attempt to add ssl support to kafka fixturesssl_support | Dana Powers | 2016-04-09 | 1 | -4/+10 | |
| | | ||||||
| * | Update conn fixture to check for HANDSHAKE state | Dana Powers | 2016-04-09 | 1 | -1/+2 | |
| | | ||||||
| * | Use selectors module in KafkaClientselectors | Dana Powers | 2016-04-09 | 1 | -1/+14 | |
| | | ||||||
 |
index : delta/python-packages/kafka-python.git | |
| github.com: mumrah/kafka-python.git |
| summaryrefslogtreecommitdiff |