openstack/deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • f6af0fac6b Add optional timeout parameter to KafkaProducer.flush() Dana Powers 2016-03-12 23:50:52 -08:00
  • eb4b2b33a5 Fix for FutureProduceResult.await on python2.6 Dana Powers 2016-03-13 08:48:08 -07:00
  • f83d294441 Move logging format config to tox.ini to avoid duplicate log capture in pytest output Dana Powers 2016-03-13 09:25:25 -07:00
  • 376e3659a8 Move logging format config to tox.ini to avoid duplicate log capture in pytest output testing Dana Powers 2016-03-13 09:25:25 -07:00
  • 7db5adf1b5 Add ignore_leadernotavailable kwarg to SimpleClient.load_metadata_for_topics Dana Powers 2016-03-13 00:09:03 -08:00
  • 7bc3b08132 Use producer retries and flush timeout in producer end-to-end test Dana Powers 2016-03-12 23:51:34 -08:00
  • e4196d5b7a Add optional timeout parameter to KafkaProducer.flush() Dana Powers 2016-03-12 23:50:52 -08:00
  • afce25267d Fix for FutureProduceResult.await on python2.6 Dana Powers 2016-03-13 08:48:08 -07:00
  • e42383dd84 Merge pull request #583 from dpkp/consumer_heartbeat_fixes Dana Powers 2016-03-12 19:01:20 -08:00
  • 561a678d1d Consumer should timeout internal iterator if heartbeat ttl is expired Dana Powers 2016-03-12 12:16:05 -08:00
  • fb0b49827f Add heartbeat timeout test Dana Powers 2016-03-12 12:14:05 -08:00
  • 047a65f1d9 factor group checking logic to KafkaConsumer._use_consumer_group() Dana Powers 2016-03-12 17:31:10 -08:00
  • 86d98c00fd Log successful heartbeat as INFO; improve heartbeat response logging Dana Powers 2016-03-11 16:47:46 -08:00
  • 0057e75ecf HeartbeatTask should reschedule heartbeat on coordinator_unknown() Dana Powers 2016-03-11 16:41:42 -08:00
  • f58b7e9b2a Add test for unknown coordinator heartbeat task Dana Powers 2016-03-11 16:36:24 -08:00
  • ccadb4dc80 Add timestamps to basic test logging Dana Powers 2016-03-12 14:56:30 -08:00
  • bbca721d74 Sync rendered fixture templates to disk to avoid races Dana Powers 2016-03-12 12:53:47 -08:00
  • 590d75a76a Improve Zookeeper / Kafka Fixture management - spawn fixtures via daemon threads - close fixtures atexit and in __del__ to avoid interpreter hangs - raise Exception on timeouts in open() Dana Powers 2016-03-12 10:19:51 -08:00
  • 4ebf28412e Log successful heartbeat as INFO; improve heartbeat response logging coordinator_unknown_heartbeat Dana Powers 2016-03-11 16:47:46 -08:00
  • f1b9b8490a HeartbeatTask should reschedule heartbeat on coordinator_unknown() Dana Powers 2016-03-11 16:41:42 -08:00
  • af2cd5e91a Add test for unknown coordinator heartbeat task Dana Powers 2016-03-11 16:36:24 -08:00
  • 11cf12ff53 Merge pull request #567 from twm/patch-1 Dana Powers 2016-03-09 09:01:25 -08:00
  • 45cb3220c7 Merge pull request #578 from stefanth/bugfix-stefanth-1 Dana Powers 2016-03-09 08:58:39 -08:00
  • b787a2211e Bug fix: KafkaConsumer.position() Stefán Þorvarðarson 2016-03-09 11:50:29 +00:00
  • d5f31e6e3c Merge pull request #573 from scribu/patch-1 Dana Powers 2016-03-04 11:55:36 -08:00
  • 1e297f57fe Refreshed patch. debian/0.9.5.1 Thomas Goirand 2016-03-02 13:57:50 +00:00
  • 775a250cbc Standards-Version: 3.9.7 (no change). Thomas Goirand 2016-03-02 13:56:43 +00:00
  • 64b3cbe92d Fixed gbp.conf Thomas Goirand 2016-03-02 13:54:17 +00:00
  • 7318df65e6 Now packaging 0.9.5 Thomas Goirand 2016-03-02 13:53:12 +00:00
  • a06de23a09 Merge tag '0.9.5' into debian/unstable Thomas Goirand 2016-03-02 13:50:29 +00:00
  • 637f47c80f Fix value_deserializer parameter in example Cristi Burcă 2016-03-02 05:56:01 +02:00
  • c8662bfa6b Fix value_serializer parameter in example Cristi Burcă 2016-03-01 20:10:54 +02:00
  • 88704428ed Fixed VCS URLs (https). Ondřej Nový 2016-02-28 15:40:27 +01:00
  • bd139242e1 Merge pull request #566 from mortenlj/master Dana Powers 2016-02-27 09:55:09 -08:00
  • 00d527f480 Update base.py Tom Most 2016-02-26 17:37:41 -08:00
  • 6b02c7dc3b Fix typo ifr.future.fail => ifr.future.failure Morten Lied Johansen 2016-02-26 12:33:04 +01:00
  • 59ac7d6ca6 Update to Kafka 0.9.0.1 for integration testing Dana Powers 2016-02-23 18:16:08 -08:00
  • 8e63068cd8 Merge pull request #564 from shichao-an/master Dana Powers 2016-02-23 18:17:43 -08:00
  • 118a06f331 Add missing imports: KafkaError Shichao An 2016-02-23 17:53:01 -08:00
  • 6c6ed8c81c Bump version for development of next release Dana Powers 2016-02-22 20:38:22 -08:00
  • 9d4045acc2 Release 1.0.1 1.0.1 Dana Powers 2016-02-19 09:02:39 -08:00
  • 9d81fc37af Update Changelog for 1.0.1 patch release Dana Powers 2016-02-18 22:56:35 -08:00
  • 29e96f82ce Mock client.ready() call to test coordinator offset fetch request Dana Powers 2016-02-18 22:56:05 -08:00
  • 6a2466b4d9 Migrate load_example.py to KafkaProducer / KafkaConsumer Dana Powers 2016-02-18 22:46:39 -08:00
  • 99bc503b1a Catch duplicate batch.done() calls -- this can happen if we maybe_expire then process a response errback Dana Powers 2016-02-18 22:46:04 -08:00
  • 642b640404 Warn if pending batches failed during flush Dana Powers 2016-02-18 21:54:37 -08:00
  • f2d10f02d3 Fix concurrency bug in RecordAccumulator.ready() Dana Powers 2016-02-18 21:54:12 -08:00
  • 2dd216b5ac Some attributes may not exist in __del__ if we failed assertions Dana Powers 2016-02-18 21:53:11 -08:00
  • 799f53f712 Fix bug in SimpleBufferPool memory condition waiting / timeout Dana Powers 2016-02-18 21:49:37 -08:00
  • 72fa7ef4fd More friendly warning when offset fetch request returns unknown topic / partition Dana Powers 2016-02-18 21:48:39 -08:00
  • 6946aa2910 Verify node ready before sending offset fetch request from coordinator Dana Powers 2016-02-18 21:48:14 -08:00
  • 3147dfd644 Merge pull request #558 from dpkp/batch_size_zero Dana Powers 2016-02-18 08:00:07 -08:00
  • abd50dc323 Merge pull request #557 from dpkp/socket_buffer_size_optional Dana Powers 2016-02-18 07:59:32 -08:00
  • 97fd705a23 Support batch_size = 0 in producer buffers Dana Powers 2016-02-17 22:43:21 -08:00
  • 9bf304ab43 Dont override system rcvbuf or sndbuf unless user configures explicitly Dana Powers 2016-02-17 22:21:36 -08:00
  • bcdefd698d Merge pull request #553 from aisch/kafka_client_fd_leak Dana Powers 2016-02-17 10:35:02 -08:00
  • d7522b0fb7 break up some circular references and close client wake pipe on __del__ aisch 2016-02-16 21:30:38 -08:00
  • 9f0db5d38b Merge pull request #550 from dpkp/range_assignor Dana Powers 2016-02-16 14:28:40 -08:00
  • c8be93b44b Add RangePartitionAssignor (and use as default); add assignor tests Dana Powers 2016-02-16 12:35:28 -08:00
  • d5c05c811e Make sure all consumers are in same generation before stopping group test Dana Powers 2016-02-16 12:32:29 -08:00
  • d1daeaad25 Improve kafka.cluster docstrings Dana Powers 2016-02-16 12:30:37 -08:00
  • 3df92c9070 Bump version for development Dana Powers 2016-02-15 23:32:33 -08:00
  • 48421e4ab4 Release 1.0.0 1.0.0 Dana Powers 2016-02-15 21:56:49 -08:00
  • 660b4de232 bootstrap node should be last resort in least_loaded_node() Dana Powers 2016-02-15 21:06:06 -08:00
  • 0d1ccc7485 Support setting kafka instance port explicitly in fixture Dana Powers 2016-02-15 20:20:56 -08:00
  • 251d4a97ce Remove unmaintained POWERED-BY doc Dana Powers 2016-02-15 20:18:50 -08:00
  • 432c0fe7d7 Use KafkaProducer / KafkaConsumer in example.py Dana Powers 2016-02-15 20:18:04 -08:00
  • 405b1a5d66 Cleanup docstring nested indent (acks values) Dana Powers 2016-02-15 19:50:59 -08:00
  • d14e878e11 Add changelog to sphinx docs; remove SimpleProducer from API list and move API up in toc Dana Powers 2016-02-15 17:27:06 -08:00
  • cff7b31d05 Update Changelog in preparation for 1.0.0 release Dana Powers 2016-02-15 17:27:01 -08:00
  • d2dbc5b3a3 Cleaner event handling in _wait_on_metadata Dana Powers 2016-02-15 19:46:48 -08:00
  • 8767914305 Remove unused internal sender lock Dana Powers 2016-02-15 18:56:45 -08:00
  • 742755d8d8 Add lock to synchronize metadata updates and future handling Dana Powers 2016-02-15 18:50:34 -08:00
  • 1f47743ff4 Add changelog to sphinx docs; remove SimpleProducer from API list and move API up in toc release Dana Powers 2016-02-15 17:27:06 -08:00
  • b42417bfaa Update Changelog in preparation for 1.0.0 release Dana Powers 2016-02-15 17:27:01 -08:00
  • bce0cad5d3 Revisit _wait_on_metadata to address timeout and error handling (Issue 539) Dana Powers 2016-02-15 16:24:02 -08:00
  • bd0caa76d0 warn (not error) on LeaderNotAvailable - this is usually not cause for concern Dana Powers 2016-02-15 16:21:45 -08:00
  • 15b4b402ea Update ClusterMetadata comments Dana Powers 2016-02-15 16:19:50 -08:00
  • b4c36ee3d3 Track set of unauthorized_topics in ClusterMetadata Dana Powers 2016-02-15 16:17:22 -08:00
  • 89b4c2ff37 Remove unused cluster._version private attribute Dana Powers 2016-02-15 16:15:50 -08:00
  • ca7cd0dd11 Keep full PartitionMetadata from MetadataResponses Dana Powers 2016-02-15 16:15:08 -08:00
  • 494800cd00 Fixup SimpleClient.topic_partitions comment Dana Powers 2016-02-15 16:13:30 -08:00
  • 7eeba0d15f Mark old kafka.common structs as Deprecated; remove unused TopicMetadata Dana Powers 2016-02-15 16:11:05 -08:00
  • 16c13f91c0 KafkaClient.connection_delay should return 0 when connecting to avoid unnecessary sleep in poll Dana Powers 2016-02-15 14:58:21 -08:00
  • b2404578d2 KAFKA-3044: Re-word consumer.poll behaviour Dana Powers 2016-02-15 14:23:38 -08:00
  • c0d6273419 TopicPartition should be importable from top-level module Dana Powers 2016-02-15 12:45:50 -08:00
  • 7c779b31db Issue 545: Convert deserializer StopIteration errors to raw Exceptions Dana Powers 2016-02-15 12:31:10 -08:00
  • c6b9f84e49 Update SimpleClient docs (Issue 543) Dana Powers 2016-02-15 11:23:16 -08:00
  • 6c213d62b6 Fixup RequestTimeoutError -> RequestTimedOutError Dana Powers 2016-02-15 11:05:41 -08:00
  • 4d17ec257f Improve KafkaClient.check_version() Dana Powers 2016-02-15 09:37:43 -08:00
  • 48a71beb2f Fix Typos (Issue 536) Dana Powers 2016-02-15 09:16:53 -08:00
  • e90094ca82 KAFKA-3191: Improve offset committing docstrings Dana Powers 2016-02-02 17:06:16 -08:00
  • d56d2fadda a few extra AssertionError messages in KafkaConsumer Dana Powers 2016-02-02 16:59:46 -08:00
  • daa082c074 KAFKA-3170: default consumer config for fetch_min_bytes should be 1 Dana Powers 2016-02-02 09:59:56 -08:00
  • 1fabef18bf Fixup: _send_offset_commit_request future should succeed w/ True, not None Dana Powers 2016-02-02 08:01:45 -08:00
  • b60df8d174 Add more debug/trace statements to sender loop Dana Powers 2016-02-02 07:57:04 -08:00
  • 22a1b6dc70 Fix accumulator bug: expired batches should be removed from the internal queue Dana Powers 2016-02-02 07:55:39 -08:00
  • 2a783d047a Add more assertions in KafkaConsumer (primarily to seek* methods) Dana Powers 2016-02-01 00:20:22 -08:00
  • 894c9aac50 Be sure to get all metadata when subscribing to a regex pattern. Dana Powers 2016-02-01 00:17:42 -08:00
  • d3d6ea939b Implement KafkaConsumer.topics() Dana Powers 2016-01-31 23:54:34 -08:00