Commits

Branch selector

 async-producer-fix

User selector

All users

Datepicker

All time

Commit History

Commits on May 29, 2015

• wrap value into object so we can modify it

  

  lukas@doubledutch.me

  committed
  3c632b6

  Copy full SHA for 3c632b6

• check if connection is available before sending messages using the async producer

  

  lukas@doubledutch.me

  committed
  2a809b9

  Copy full SHA for 2a809b9

Commits on May 18, 2015

• Merge pull request #342 from wting/fix_consumer_falsiness

  Show description for 67424a2
  

  Dana Powers

  committed
  67424a2

  Copy full SHA for 67424a2

• Check vs None directly.

  

  wting

  authored and

  Dana Powers

  committed
  01eb735

  Copy full SHA for 01eb735

Commits on May 14, 2015

• Merge pull request #376 from hellais/fix/offset

  Show description for f020c45
  dpkp

  committed
  f020c45

  Copy full SHA for f020c45

• Fix calling of _offsets

  Show description for 353c01e
  hellais

  committed
  353c01e

  Copy full SHA for 353c01e

Commits on Apr 13, 2015

• Merge pull request #367 from dpkp/clean_metadata_refresh

  Show description for cd81cf0
  dpkp

  committed
  cd81cf0

  Copy full SHA for cd81cf0

Commits on Apr 12, 2015

• Update debug log messages in client.load_metadata_for_topics

  

  Dana Powers

  committed
  6326e18

  Copy full SHA for 6326e18

• clean local metadata before requesting refresh in load_metadata_for_topics()

  

  Dana Powers

  committed
  d5c9a11

  Copy full SHA for d5c9a11

• Simplify client.reset_topic_metadata

  

  Dana Powers

  committed
  fbc242f

  Copy full SHA for fbc242f

• Merge pull request #366 from dpkp/failed_payloads

  Show description for 19643fb
  dpkp

  committed
  19643fb

  Copy full SHA for 19643fb

Commits on Apr 6, 2015

• Improve send_produce_request docstring

  

  Dana Powers

  committed
  94f4c9e

  Copy full SHA for 94f4c9e

• Add debug logging for all broker-aware requests/responses

  

  Dana Powers

  committed
  fdec16d

  Copy full SHA for fdec16d

• Refactor KafkaClient._send_broker_aware_request to return a list of responses

  Show description for 5cc0513
  

  Dana Powers

  committed
  5cc0513

  Copy full SHA for 5cc0513

• 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

Pagination

Previous

Next