Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 13, 2015

• Merge pull request #289 from alexcb/broker-error-class-refactoring

  Show description for 28a8385
  dpkp

  committed
  28a8385

  Copy full SHA for 28a8385

• Merge pull request #286 from Dinoshauer/expose-KafkaConsumer-in-all

  Show description for 4c9ffa1
  dpkp

  committed
  4c9ffa1

  Copy full SHA for 4c9ffa1

• Merge pull request #288 from alexcb/master

  Show description for 8178b9d
  dpkp

  committed
  8178b9d

  Copy full SHA for 8178b9d

Commits on Jan 11, 2015

• Use reflection to avoid multiple errno definitions

  alexcb

  committed
  01c1481

  Copy full SHA for 01c1481

Commits on Jan 9, 2015

• Updated unittests to explicitly set random_start value

  alexcb

  committed
  d6f1a0a

  Copy full SHA for d6f1a0a

• Randomize start by default for SimpleProducer

  Show description for 9c643e0
  alexcb

  committed
  9c643e0

  Copy full SHA for 9c643e0

• KafkaConsumer should be in __all__.

  dinoshauer

  committed
  c2a23b9

  Copy full SHA for c2a23b9

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

Pagination

Previous

Next