Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 5, 2015

• Add retry and queue size on async producer

  Show description for de01c22
  ashangit

  committed
  de01c22

  Copy full SHA for de01c22

Commits on Jan 2, 2015

• Merge pull request #281 from meandthewallaby/compressed-key

  Show description for 02c2b46
  wizzat

  committed
  02c2b46

  Copy full SHA for 02c2b46

• Added keys to compressed messages (both gzip and snappy).

  meandthewallaby

  committed
  6603088

  Copy full SHA for 6603088

Commits on Dec 17, 2014

• Merge pull request #234 from dpkp/high_level_consumer

  Show description for 9c5216a
  wizzat

  committed
  9c5216a

  Copy full SHA for 9c5216a

• Merge pull request #277 from pubnub/master

  Show description for 30c87fb
  wizzat

  committed
  30c87fb

  Copy full SHA for 30c87fb

Commits on Dec 15, 2014

• added a send_messages api to KeyedProducer

  Show description for d145525
  

  Jordan Shaw

  committed
  d145525

  Copy full SHA for d145525

• Add some jitter to refresh_leader_backoff_ms, per wizzat review

  

  Dana Powers

  committed
  29cae3e

  Copy full SHA for 29cae3e

• Simplify BYTES_CONFIGURATION_KEYS logic, per wizzat review

  

  Dana Powers

  committed
  e3fd29c

  Copy full SHA for e3fd29c

• Fixup call to self._client.get_partition_ids_for_topic -- use encoded topic bytes

  

  Dana Powers

  committed
  d27d49f

  Copy full SHA for d27d49f

• Use kafka.util.kafka_bytestring to encode utf-8 when necessary

  

  Dana Powers

  committed
  ed893c3

  Copy full SHA for ed893c3

• OffsetCommit metadata must be bytes

  

  Dana Powers

  committed
  209a8f2

  Copy full SHA for 209a8f2

• Add private methods _does_auto_commit_ms and _does_auto_commit_messages

  

  Dana Powers

  committed
  08df93b

  Copy full SHA for 08df93b

• Make TIMEOUT_MS configurable in test_kafka_consumer__blocking

  

  Dana Powers

  committed
  1a06f79

  Copy full SHA for 1a06f79

• Merge conflict w/ assertEqual (assertEquals deprecated)

  

  Dana Powers

  committed
  9e1b203

  Copy full SHA for 9e1b203

• Fix task_done checks when no previous commit exists; add test

  

  Dana Powers

  committed
  b80e83b

  Copy full SHA for b80e83b

• Force absolue_imports in kafka/consumer/kafka.py

  

  Dana Powers

  committed
  206560a

  Copy full SHA for 206560a

• Move KafkaConsumer to kafka.consumer.kafka module; make available for import from kafka at top-level

  

  Dana Powers

  committed
  6b44828

  Copy full SHA for 6b44828

• Use six for py3 support in KafkaConsumer

  Show description for 6e6ae53
  

  Dana Powers

  committed
  6e6ae53

  Copy full SHA for 6e6ae53

• Update docstrings w/ current interface / config defaults

  

  Dana Powers

  committed
  391b532

  Copy full SHA for 391b532

• Raise KafkaConfigurationError during fetch_messages if not topics/partitions configured

  

  Dana Powers

  committed
  742af4f

  Copy full SHA for 742af4f

• Move auto-commit checks to task_done; add support for auto_commit_interval_messages

  

  Dana Powers

  committed
  07ff623

  Copy full SHA for 07ff623

• Add private methods to manage internal _msg_iter

  

  Dana Powers

  committed
  7caf9be

  Copy full SHA for 7caf9be

• Reorder methods, add docstrings to public methds, section comments for private methods

  

  Dana Powers

  committed
  08f6ad9

  Copy full SHA for 08f6ad9

• Use 4-space indents

  

  Dana Powers

  committed
  5b88298

  Copy full SHA for 5b88298

• Add a few basic KafkaConsumer tests

  

  Dana Powers

  committed
  54ecfea

  Copy full SHA for 54ecfea

• Add docstring to get_partition_offsets; use request_time_ms and max_num_offsets var names

  

  Dana Powers

  committed
  26e18ce

  Copy full SHA for 26e18ce

• Add docstring to configure()

  

  Dana Powers

  committed
  9dd7d7e

  Copy full SHA for 9dd7d7e

• raise KafkaConfigurationError in commit() if there is no configured 'group_id'; add docstring

  

  Dana Powers

  committed
  8dc3623

  Copy full SHA for 8dc3623

• _should_auto_commit is private

  

  Dana Powers

  committed
  67aa1a1

  Copy full SHA for 67aa1a1

• Support setting offsets in set_topic_partitions(); reorganize offsets initialization

  

  Dana Powers

  committed
  d5ec0a6

  Copy full SHA for d5ec0a6

• _client is private var

  

  Dana Powers

  committed
  93dd705

  Copy full SHA for 93dd705

• Move kafka._msg_iter initialization from __init__() to next()

  

  Dana Powers

  committed
  80dfaeb

  Copy full SHA for 80dfaeb

• self._topics is private; fixup topic iterations for new TopicAndPartition list; add more type checks to set_topic_and_partitions

  

  Dana Powers

  committed
  e702880

  Copy full SHA for e702880

• Add set_topic_partitions method to configure topics/partitions to consume

  

  Dana Powers

  committed
  62a7189

  Copy full SHA for 62a7189

• Use client.get_partition_ids_for_topic

  

  Dana Powers

  committed
  4c111d3

  Copy full SHA for 4c111d3

Pagination

Previous

Next