1
38%
master: 38%

Ran 14 May 2015 06:30PM UTC

Files 24

Run time 2s

Badge

Embed ▾

Committed 14 May 2015 06:28PM UTC coverage: 71.677% (+0.06%) from 71.615%

Job # BROKERS=localhost:9092,localhost:9093,localhost:9094 ZOOKEEPER=localhost:2181 KAFKA_BIN=/home/travis/kafka-bin

Build Type

push

travis-ci

Committed by

emmett9001

Commit Message

If the consumer has stopped running, break out of blocking consume().

When using a BalancedConsumer with consumer_timeout_ms=-1 and block=True (that is, full blocking consume() calls enabled), a rebalance (and thus a reallocation of the internal SimpleConsumer) caused the timeout loop in SimpleConsumer.consume() to spin infinitely. This caused execution in the caller of consume() to halt, resulting in a 'frozen' consumer at the application level.
This commit addresses this issue by ensuring that the loop is broken if the consumer has stopped running (which happens during a rebalance).

One side effect of this commit is that consumer applications that call BalancedConsumer.consume() with block=True and consumer_timeout_ms=-1 will now have to handle that function returning None messages. Previously, it didn't need to, but this commit means that even the fully-blocking mode will occasionally return None during a rebalance.

This commit addresses ticket #164

Run Details

1321 of 1843 relevant lines covered (71.68%)

0.72 hits per line

Parsely / pykafka / 571 / 1
38%
master: 38%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 571.1 (BROKERS=localhost:9092,localhost:9093,localhost:9094 ZOOKEEPER=localhost:2181 KAFKA_BIN=/home/travis/kafka-bin)

Parsely / pykafka / 571 / 1 38% master: 38%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Source Files on job 571.1 (BROKERS=localhost:9092,localhost:9093,localhost:9094 ZOOKEEPER=localhost:2181 KAFKA_BIN=/home/travis/kafka-bin)

Parsely / pykafka / 571 / 1
38%
master: 38%

README BADGES
x