Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Apr 6, 2015

• Merge pull request #365 from dpkp/kafka_consumer_fixup

  Show description for 04a3816
  dpkp

  committed
  04a3816

  Copy full SHA for 04a3816

Commits on Apr 5, 2015

• Use kafka_bytestring when decoding message topics in KafkaConsumer.fetch_messages

  

  Dana Powers

  committed
  c0fc334

  Copy full SHA for c0fc334

• Use list comprehension on _topics in KafkaConsumer.fetch_messages

  

  Dana Powers

  committed
  811fd4c

  Copy full SHA for 811fd4c

• call _consume_topic_partition() before storing offset

  Show description for 87b2ca8
  

  Dana Powers

  committed
  87b2ca8

  Copy full SHA for 87b2ca8

Commits on Apr 4, 2015

• Fix python3 str/bytes bug in KafkaConsumer.set_topic_partitions({(topic, partition): offset, })

  

  Dana Powers

  committed
  e99a751

  Copy full SHA for e99a751

• Merge pull request #360 from dpkp/atexit_cleanup

  Show description for 46ee816
  dpkp

  committed
  46ee816

  Copy full SHA for 46ee816

• Merge pull request #361 from kecaps/master

  Show description for 45c05d0
  dpkp

  committed
  45c05d0

  Copy full SHA for 45c05d0

Commits on Apr 3, 2015

• Make external API consistently support python3 strings for topic.

  

  Space

  committed
  1c856e8

  Copy full SHA for 1c856e8

Commits on Mar 31, 2015

• Register atexit handlers for consumer and producer thread/multiprocess cleanup (not __del__)

  

  Dana Powers

  committed
  47989db

  Copy full SHA for 47989db

• Merge pull request #356 from dpkp/always_fetch_offsets

  Show description for 9fd0811
  dpkp

  committed
  9fd0811

  Copy full SHA for 9fd0811

Commits on Mar 30, 2015

• Bulk fetch offset partitions in base consumer -- suggested by ecanzonieri

  

  Dana Powers

  committed
  1d252bf

  Copy full SHA for 1d252bf

• Merge pull request #355 from dpkp/correlation_id_modulo

  Show description for 6fc6856
  dpkp

  committed
  6fc6856

  Copy full SHA for 6fc6856

• Fetch previously committed offsets in base consumer class so long as

  Show description for b6d032c
  

  Dana Powers

  committed
  b6d032c

  Copy full SHA for b6d032c

• Skip these tests: no OffsetCommitRequest for 0.8.0

  

  vshlapakov

  authored and

  Dana Powers

  committed
  32dd817

  Copy full SHA for 32dd817

• Added basic tests for load_initial_offsets option

  

  vshlapakov

  authored and

  Dana Powers

  committed
  92a3737

  Copy full SHA for 92a3737

• Add test case for MP Consumer auto commit

  Show description for 4bc30a2
  

  alisaifee

  authored and

  Dana Powers

  committed
  4bc30a2

  Copy full SHA for 4bc30a2

• Merge pull request #357 from dpkp/del_consumer_stop

  Show description for d05fccb
  dpkp

  committed
  d05fccb

  Copy full SHA for d05fccb

• Stop consumers on delete

  

  Dana Powers

  committed
  bb68965

  Copy full SHA for bb68965

• Add test for correlation_id rollover

  

  Dana Powers

  committed
  1313388

  Copy full SHA for 1313388

• Rollover KafkaClient correlation ids at 2**31 to keep within int32 protocol encoding

  

  Dana Powers

  committed
  a4b4391

  Copy full SHA for a4b4391

• Merge pull request #341 from dpkp/kafka_consumer_docs

  Show description for bb1c11e
  dpkp

  committed
  bb1c11e

  Copy full SHA for bb1c11e

Commits on Mar 29, 2015

• Use bootstrap_servers interface in tests

  

  Dana Powers

  committed
  35b8f5b

  Copy full SHA for 35b8f5b

• Add sphinx_rtd_theme to docs requirements.txt

  

  Dana Powers

  committed
  5652f59

  Copy full SHA for 5652f59

• Updates to KafkaConsumer usage docs

  

  Dana Powers

  committed
  c1ca3bf

  Copy full SHA for c1ca3bf

• fixup kafka consumer docstring

  

  Dana Powers

  committed
  9be4146

  Copy full SHA for 9be4146

• Move KafkaConsumer usage examples to docs/usage; Put KeyedProducer usage right after SimpleProducer

  

  Dana Powers

  committed
  484f1a4

  Copy full SHA for 484f1a4

• Improve KafkaConsumer docstrings

  

  Dana Powers

  committed
  eb5fd4a

  Copy full SHA for eb5fd4a

• Merge pull request #340 from dpkp/deprecate_metadata_broker_list

  Show description for fd204dc
  dpkp

  committed
  fd204dc

  Copy full SHA for fd204dc

• Merge pull request #336 from scrapinghub/feature-mp-consumer-params

  Show description for f35995a
  dpkp

  committed
  f35995a

  Copy full SHA for f35995a

• Merge pull request #350 from ecanzonieri/enable_commit_on_seek

  Show description for 9a8cd15
  dpkp

  committed
  9a8cd15

  Copy full SHA for 9a8cd15

• Merge pull request #338 from dpkp/structs_reorg

  Show description for 1dd7b17
  dpkp

  committed
  1dd7b17

  Copy full SHA for 1dd7b17

• Merge pull request #337 from dpkp/gzip_context

  Show description for d02276e
  dpkp

  committed
  d02276e

  Copy full SHA for d02276e

• Merge pull request #329 from vshlapakov/feature-batch-msg-keys

  Show description for 1a5cb03
  dpkp

  committed
  1a5cb03

  Copy full SHA for 1a5cb03

Commits on Mar 25, 2015

• Manageable queue.put() operation for MPConsumer processes

  vshlapakov

  committed
  fb118fb

  Copy full SHA for fb118fb

Commits on Mar 24, 2015

• Added pylint.rc: ignoring SyncManager for pylint

  vshlapakov

  committed
  9d5c93e

  Copy full SHA for 9d5c93e

Pagination

Previous

Next