openstack/deb-python-kafka
Code Issues Proposed changes

Commit Graph

  • be9f4099e0 use setUp / tearDown to rebuild fixtures for each test in test_failover_integration Dana Powers 2015-02-07 21:53:33 -08:00
  • 3ab9a42fcf Merge pull request #315 from dpkp/sorted_partition_ids Mark Roberts 2015-02-09 10:19:24 -08:00
  • cc6e8bbb22 Always return sorted partition ids in KafkaClient.get_partition_ids_for_topic() Dana Powers 2015-02-08 21:35:16 -08:00
  • f206a4bbf0 Fixup index.rst Dana Powers 2015-02-05 10:58:01 -08:00
  • 6cceb76234 Update docs/index.rst for sphinx/RTD Dana Powers 2015-02-05 10:54:11 -08:00
  • c29cfdc156 2014 -> 2015 David Arthur 2015-02-03 20:03:07 -05:00
  • 91156f6ae4 Adding ReadTheDocs badge David Arthur 2015-02-03 19:54:39 -05:00
  • c00dc274f9 Removing traces of queue.py David Arthur 2015-02-03 19:52:04 -05:00
  • a421999992 Removing queue.py David Arthur 2015-02-03 19:44:03 -05:00
  • 93e625ddd4 Trying to get ReadTheDocs working David Arthur 2015-02-03 19:34:04 -05:00
  • 13b1dbe56f Bump VERSION for development of next release Dana Powers 2015-02-03 16:26:12 -08:00
  • 8675c3e3e6 Update LICENSE v0.9.3 0.9.3 David Arthur 2015-02-03 18:51:32 -05:00
  • 39dccaa6fe Bump VERSION Dana Powers 2015-02-03 15:46:11 -08:00
  • fd99a5785c Merge pull request #310 from dpkp/kafka_python_0_9_3 Dana Powers 2015-02-03 15:04:02 -08:00
  • cd0bb3bfbd Update README and CHANGES for 0.9.3 release Dana Powers 2015-02-03 11:12:46 -08:00
  • d3030cc72d Add 0.8.2.0 to integration tests (and use recommended scala 2.10 by default) Dana Powers 2015-02-03 10:51:45 -08:00
  • 202b137069 Merge pull request #307 from sontek/enable_coveralls Dana Powers 2015-02-03 13:35:54 -08:00
  • fa41ec6da7 Merge pull request #312 from dpkp/reentrant_timer_py26 Dana Powers 2015-02-03 12:33:58 -08:00
  • a21f701e1e Fix python2.6 threading.Event bug in ReentrantTimer Dana Powers 2015-02-03 11:35:51 -08:00
  • f0f37445b4 Merge pull request #306 from sontek/catch_topic_not_bytes Mark Roberts 2015-02-02 10:16:33 -08:00
  • 4379355450 Merge pull request #309 from zhaopengzp/master Mark Roberts 2015-02-02 10:13:42 -08:00
  • c6a5aafa40 fix circle reference zhaopengzp 2015-02-02 10:49:02 +08:00
  • 37d0b7f9db Retry failed partitions and add integration tests Enrico Canzonieri 2015-01-26 16:24:20 -08:00
  • 9ab8415ed7 Merge branch 'master' of github.com:mumrah/kafka-python into validate_consumer_offset Enrico Canzonieri 2015-01-26 15:01:51 -08:00
  • f517ddf283 Make SimpleConsumer auto_offset_reset more like KafkaConsumer Enrico Canzonieri 2015-01-26 14:40:49 -08:00
  • 8ebef4b256 This enables coveralls with travis John Anderson 2015-01-24 16:37:42 -08:00
  • 72bec18add Just encode to bytes if it isn't bytes. John Anderson 2015-01-24 16:32:09 -08:00
  • 3a52d18faf Alert if the topic is not sent as bytes John Anderson 2015-01-23 15:39:15 -08:00
  • 587206ff6a Merge pull request #282 from wedaly/sphinx-api-docs Dana Powers 2015-01-23 09:41:03 -08:00
  • 01f378328e Add Sphinx API docs Will Daly 2015-01-04 12:23:10 -05:00
  • e6b37c00c5 Merge pull request #295 from dpkp/kafka_0_8_2 Mark Roberts 2015-01-15 00:49:46 -08:00
  • 21a5ca834b Catch ReplicaNotAvailableError in MetadataResponse -- per kafka-devs, this error can and should be ignored Dana Powers 2015-01-14 19:15:54 -08:00
  • 8a5fe3184a Move 0.8.2-beta resources to 0.8.2.0 Dana Powers 2015-01-14 19:10:17 -08:00
  • 6bc2c7aada use a list in send_offset_request Enrico Canzonieri 2015-01-14 15:21:27 -08:00
  • 878e4cefb6 Implement offsets reset when OffsetOutOfRangeError Enrico Canzonieri 2015-01-06 17:33:21 +01:00
  • 4e78199301 Add 0.8.2.0 to some kafka_version tests Dana Powers 2015-01-14 12:58:41 -08:00
  • e87bff6eb3 Change ZookeeperFixture wait_for regex to support newer zk version used with 0.8.2.0 Dana Powers 2015-01-14 12:55:40 -08:00
  • 6f7e79b309 Fix KafkaFixture child stdout / stderr capture Dana Powers 2015-01-14 12:54:51 -08:00
  • 5ab535521f Just copied over the 0.8.1.1 conf files Dana Powers 2014-12-11 17:04:25 -08:00
  • 28a838516b Merge pull request #289 from alexcb/broker-error-class-refactoring Dana Powers 2015-01-12 23:50:07 -08:00
  • 4c9ffa1265 Merge pull request #286 from Dinoshauer/expose-KafkaConsumer-in-all Dana Powers 2015-01-12 23:42:45 -08:00
  • 8178b9d61c Merge pull request #288 from alexcb/master Dana Powers 2015-01-12 23:31:38 -08:00
  • 01c1481248 Use reflection to avoid multiple errno definitions Alex Couture-Beil 2015-01-09 16:34:59 -08:00
  • d6f1a0a6e4 Updated unittests to explicitly set random_start value Alex Couture-Beil 2015-01-09 11:48:05 -08:00
  • 9c643e0218 Randomize start by default for SimpleProducer Alex Couture-Beil 2015-01-09 10:54:31 -08:00
  • c2a23b9d87 KafkaConsumer should be in __all__. Kasper Jacobsen 2015-01-09 10:47:35 +01:00
  • 02c2b46900 Merge pull request #281 from meandthewallaby/compressed-key Mark Roberts 2015-01-02 09:54:55 -08:00
  • 6603088f0a Added keys to compressed messages (both gzip and snappy). Eric Hewitt 2015-01-02 11:34:38 -05:00
  • 9c5216a97f Merge pull request #234 from dpkp/high_level_consumer Mark Roberts 2014-12-16 20:49:13 -08:00
  • 30c87fb2d7 Merge pull request #277 from pubnub/master Mark Roberts 2014-12-16 20:45:20 -08:00
  • d14552580c added a send_messages api to KeyedProducer Jordan Shaw 2014-12-15 15:56:02 -08:00
  • 29cae3e40b Add some jitter to refresh_leader_backoff_ms, per wizzat review Dana Powers 2014-12-11 16:37:25 -08:00
  • e3fd29cb37 Simplify BYTES_CONFIGURATION_KEYS logic, per wizzat review Dana Powers 2014-12-11 16:36:41 -08:00
  • d27d49fd6b Fixup call to self._client.get_partition_ids_for_topic -- use encoded topic bytes Dana Powers 2014-12-11 16:36:12 -08:00
  • ed893c3bcf Use kafka.util.kafka_bytestring to encode utf-8 when necessary Dana Powers 2014-12-11 16:35:15 -08:00
  • 209a8f28e6 OffsetCommit metadata must be bytes Dana Powers 2014-09-21 20:55:41 -07:00
  • 08df93b3f9 Add private methods _does_auto_commit_ms and _does_auto_commit_messages Dana Powers 2014-09-21 19:34:48 -07:00
  • 1a06f79cb8 Make TIMEOUT_MS configurable in test_kafka_consumer__blocking Dana Powers 2014-09-17 13:53:04 -07:00
  • 9e1b203069 Merge conflict w/ assertEqual (assertEquals deprecated) Dana Powers 2014-09-17 13:49:55 -07:00
  • b80e83b733 Fix task_done checks when no previous commit exists; add test Dana Powers 2014-09-17 13:49:23 -07:00
  • 206560a74b Force absolue_imports in kafka/consumer/kafka.py Dana Powers 2014-09-16 22:52:13 -07:00
  • 6b44828685 Move KafkaConsumer to kafka.consumer.kafka module; make available for import from kafka at top-level Dana Powers 2014-09-16 22:31:19 -07:00
  • 6e6ae53327 Use six for py3 support in KafkaConsumer Log connection failures w/ traceback in kafka/client.py Dana Powers 2014-09-16 16:00:14 -07:00
  • 391b53201f Update docstrings w/ current interface / config defaults Dana Powers 2014-09-15 22:49:38 -07:00
  • 742af4f7e0 Raise KafkaConfigurationError during fetch_messages if not topics/partitions configured Dana Powers 2014-09-15 22:36:53 -07:00
  • 07ff623392 Move auto-commit checks to task_done; add support for auto_commit_interval_messages Dana Powers 2014-09-15 22:36:12 -07:00
  • 7caf9bef49 Add private methods to manage internal _msg_iter Dana Powers 2014-09-15 21:49:46 -07:00
  • 08f6ad9455 Reorder methods, add docstrings to public methds, section comments for private methods Dana Powers 2014-09-15 21:48:04 -07:00
  • 5b882981d1 Use 4-space indents Dana Powers 2014-09-15 21:16:49 -07:00
  • 54ecfeaec0 Add a few basic KafkaConsumer tests Dana Powers 2014-09-15 18:08:00 -07:00
  • 26e18ce0c0 Add docstring to get_partition_offsets; use request_time_ms and max_num_offsets var names Dana Powers 2014-09-14 23:40:40 -07:00
  • 9dd7d7e07c Add docstring to configure() Dana Powers 2014-09-14 23:38:48 -07:00
  • 8dc3623208 raise KafkaConfigurationError in commit() if there is no configured 'group_id'; add docstring Dana Powers 2014-09-14 23:38:24 -07:00
  • 67aa1a1c04 _should_auto_commit is private Dana Powers 2014-09-14 23:37:32 -07:00
  • d5ec0a6021 Support setting offsets in set_topic_partitions(); reorganize offsets initialization Dana Powers 2014-09-14 23:37:07 -07:00
  • 93dd705ea7 _client is private var Dana Powers 2014-09-14 23:33:43 -07:00
  • 80dfaeb9a7 Move kafka._msg_iter initialization from __init__() to next() Dana Powers 2014-09-14 23:26:17 -07:00
  • e702880bda self._topics is private; fixup topic iterations for new TopicAndPartition list; add more type checks to set_topic_and_partitions Dana Powers 2014-09-14 10:42:04 -07:00
  • 62a71892a6 Add set_topic_partitions method to configure topics/partitions to consume Dana Powers 2014-09-14 10:07:58 -07:00
  • 4c111d3d7c Use client.get_partition_ids_for_topic Dana Powers 2014-09-13 19:34:44 -07:00
  • 53763510c7 Use configure() to check and set configuration keys Dana Powers 2014-09-13 19:34:08 -07:00
  • b264d8f517 add private methods _set_consumer_timeout_start() and _check_consumer_timeout() Dana Powers 2014-09-11 11:44:53 -07:00
  • 82b3e011fa Handle FailedPayloadsError on client.send_fetch_request; permit offsets(); update docstring Dana Powers 2014-09-11 11:41:51 -07:00
  • fa6738b8f4 A simpler kafka consumer: Dana Powers 2014-09-11 00:12:38 -07:00
  • 02124907ff Merge pull request #276 from jettify/fix-pending Mark Roberts 2014-12-15 09:34:00 -08:00
  • ae79eff49b fix pending method Nickolai Novik 2014-12-15 01:16:50 +02:00
  • 3fc4dca1db Merge pull request #274 from sunisdown/master Dana Powers 2014-12-11 20:24:03 -08:00
  • b47c0e67ae update low level sunisdown 2014-12-11 15:42:29 +08:00
  • 3689529a61 Merge pull request #268 from se7entyse7en/keyed_message Mark Roberts 2014-11-26 10:30:02 -08:00
  • a9e77bdaa2 Fixed TestKafkaProducerIntegration Lou Marvin Caraig 2014-11-26 13:06:21 +01:00
  • 2716d06ea0 Added raise of TypeError for non bytes key Lou Marvin Caraig 2014-11-26 13:05:23 +01:00
  • 664240ab4d Key is passed when creating messages for both async=False and async=True Lou Marvin Caraig 2014-11-26 11:53:57 +01:00
  • 7041a27e20 Added private method _send_messages that can accept kwargs Lou Marvin Caraig 2014-11-26 11:50:39 +01:00
  • 813898781f Added optional argument key to create_message_set function Lou Marvin Caraig 2014-11-26 11:48:06 +01:00
  • 52ec0782b7 Make sure to include kafka.partitioner in setup package spec Dana Powers 2014-09-25 16:25:38 -07:00
  • ffaf9c3335 Merge pull request #243 from wizzat/issue_241 Dana Powers 2014-09-23 21:48:01 -07:00
  • 9b776b2225 Fixes issue #241, adds kafka.consumer and kafka.producer packages Mark Roberts 2014-09-23 21:09:52 -07:00
  • c063e30a12 Merge pull request #242 from wizzat/pr_225 Mark Roberts 2014-09-23 15:13:13 -07:00
  • 2e3d6dbde0 Merge pull request #238 from dpkp/simple_consumer_get_messages_timeout Mark Roberts 2014-09-23 14:15:51 -07:00
  • 2fb6e23b32 Resolve merge conflict in PR #225 Mark Roberts 2014-09-23 14:12:30 -07:00