Commits

Branch selector

 master

User selector

All users

Datepicker

All time

Commit History

Commits on Jan 13, 2016

• Merge pull request #507 from dpkp/deprecation_warnings

  Show description for 1f6be11
  dpkp

  committed
  1f6be11

  Copy full SHA for 1f6be11

• Merge pull request #503 from dpkp/iterator_fetches

  Show description for 22f84bf
  dpkp

  committed
  22f84bf

  Copy full SHA for 22f84bf

• Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection

  

  Dana Powers

  committed
  4079a58

  Copy full SHA for 4079a58

Commits on Jan 12, 2016

• Sleep in KafkaConsumer iterator if no partition assignment; dont block in poll if no in-flight fetches

  

  Dana Powers

  committed
  3e62206

  Copy full SHA for 3e62206

• Remove sleep call in client.poll -- expect callers to manage this and log warning

  

  Dana Powers

  committed
  22e84a5

  Copy full SHA for 22e84a5

• Move consumer_timeout handling to private method

  

  Dana Powers

  committed
  dcd62b7

  Copy full SHA for dcd62b7

• Attempt to pipeline fetchrequests in iterator

  

  Dana Powers

  committed
  cc3e1cc

  Copy full SHA for cc3e1cc

• Use private deque to track in-flight fetchrequests

  

  Dana Powers

  committed
  e58b447

  Copy full SHA for e58b447

• Add mocking to test_coordinator::test_close to fix random test failure (via travis logs)

  

  Dana Powers

  committed
  dcad3fe

  Copy full SHA for dcad3fe

Commits on Jan 11, 2016

• Update docstring and comments in _create_fetch_requests re KAFKA-2978

  

  Dana Powers

  committed
  1c4a8bf

  Copy full SHA for 1c4a8bf

• Reorganize init_fetches calls during iteration

  Show description for 458bdb5
  

  Dana Powers

  committed
  458bdb5

  Copy full SHA for 458bdb5

• Check for assignment changes before yielding new record

  

  Dana Powers

  committed
  76e7d13

  Copy full SHA for 76e7d13

• Fetcher logging should be debug or trace (left higher during testing)

  

  Dana Powers

  committed
  0adb71a

  Copy full SHA for 0adb71a

• Merge pull request #496 from dpkp/idle_sleep

  Show description for 829b037
  dpkp

  committed
  829b037

  Copy full SHA for 829b037

• Pass consumer timeout to client.poll() in iterator; check timeout before iterating fetcher

  

  Dana Powers

  committed
  ecb4d49

  Copy full SHA for ecb4d49

• Fix sec / millisec unit bug in KafkaConsumer._poll_once()

  

  Dana Powers

  committed
  b86daaf

  Copy full SHA for b86daaf

• Receive all available responses in client._poll

  

  Dana Powers

  committed
  d2f1360

  Copy full SHA for d2f1360

• If a completed future is polled, do not block

  

  Dana Powers

  committed
  5fa8c88

  Copy full SHA for 5fa8c88

• Avoid CPU spinnning when there are no sockets to read

  

  Dana Powers

  committed
  1fd5960

  Copy full SHA for 1fd5960

• Fix delayed_task timeout commit 45d26b6

  

  Dana Powers

  committed
  5d2886b

  Copy full SHA for 5d2886b

• Merge pull request #502 from dpkp/task_poll_timeout

  Show description for ca08f75
  dpkp

  committed
  ca08f75

  Copy full SHA for ca08f75

• Log generation and member_id in threaded consumer group test

  

  Dana Powers

  committed
  8ae2a30

  Copy full SHA for 8ae2a30

• Fix debug logging call in PR 500

  

  Dana Powers

  committed
  1eaad6f

  Copy full SHA for 1eaad6f

Commits on Jan 10, 2016

• Improve KafkaConsumer iterator loop timeouts

  Show description for 98e4ab3
  

  Dana Powers

  committed
  98e4ab3

  Copy full SHA for 98e4ab3

• Improve cluster.ttl() readability

  

  Dana Powers

  committed
  cc4cf23

  Copy full SHA for cc4cf23

• Check delayed task timeout in client.poll()

  

  Dana Powers

  committed
  45d26b6

  Copy full SHA for 45d26b6

• Remove old kafka.consumer.kafka module

  

  Dana Powers

  committed
  7ee73df

  Copy full SHA for 7ee73df

• Merge pull request #500 from dpkp/kafka-2978

  Show description for 2d4b0d1
  dpkp

  committed
  2d4b0d1

  Copy full SHA for 2d4b0d1

• KAFKA-2978: consumer stops fetching when consumed and fetch positions get out of sync

  

  Dana Powers

  committed
  9837927

  Copy full SHA for 9837927

• Merge pull request #501 from dpkp/coordinator_tests

  Show description for 814b599
  dpkp

  committed
  814b599

  Copy full SHA for 814b599

• Add ConsumerCoordinator unit tests

  

  Dana Powers

  committed
  240f702

  Copy full SHA for 240f702

• Merge pull request #499 from dpkp/handle_disconnect

  Show description for 0a62cc1
  dpkp

  committed
  0a62cc1

  Copy full SHA for 0a62cc1

• ConsumerCoordinator cleanups

  Show description for bbd6444
  

  Dana Powers

  committed
  bbd6444

  Copy full SHA for bbd6444

• Add error checking to mark_for_reassignment

  

  Dana Powers

  committed
  35ed2e7

  Copy full SHA for 35ed2e7

• Move ConsumerProtocol definition to kafka.coordinator.protocol

  

  Dana Powers

  committed
  b710495

  Copy full SHA for b710495

Pagination

Previous

Next