729
88%

Ran 22 Oct 2015 03:19PM UTC

Jobs 25

Files 22

Run time 26min

Badge

Embed ▾

pending completion

Build # 729

Build Type

Pull #467

travis-ci

Committed by

bschopman

Commit Message

Prevents crashing communication thread of async producer

If an uncaught exception occurs in _send_messages() the thread sending
data to Kafka (asynchronously) will crash and the queue will never be
emptied. To reproduce:
1) Run an Async producer.
2) Kill the Kafka server.
3) Restart the Kafka server.
The communication thread dies shortly after step 2. After step 3 the
communication does not resume without this commit.

The changes in both files prevent an Exception from being thrown through
to do main communication process, which could cause the crash.

Pull Request Pull Request #467: Prevents crashing communication thread of async producer

Run Details

1739 of 1971 relevant lines covered (88.23%)

20.55 hits per line

Uncovered Existing Lines

Lines	Coverage	∆	File
13	100.0		kafka/producer/base.py

Jobs

ID	Job ID	Ran	Coverage
1	729.1 (UNIT_AND_LINT_ONLY=true)	22 Oct 2015 03:19PM UTC	66.72	Travis Job 729.1
2	729.2 (KAFKA_VERSION=0.8.0)	22 Oct 2015 03:22PM UTC	82.39	Travis Job 729.2
3	729.3 (KAFKA_VERSION=0.8.1)	22 Oct 2015 03:23PM UTC	87.06	Travis Job 729.3
4	729.4 (KAFKA_VERSION=0.8.1.1)	22 Oct 2015 03:23PM UTC	87.37	Travis Job 729.4
5	729.5 (KAFKA_VERSION=0.8.2.1)	22 Oct 2015 03:22PM UTC	87.16	Travis Job 729.5
6	729.6 (UNIT_AND_LINT_ONLY=true)	22 Oct 2015 03:21PM UTC	66.72	Travis Job 729.6
7	729.7 (KAFKA_VERSION=0.8.0)	22 Oct 2015 03:27PM UTC	82.55	Travis Job 729.7
8	729.8 (KAFKA_VERSION=0.8.1)	22 Oct 2015 03:28PM UTC	87.32	Travis Job 729.8
9	729.9 (KAFKA_VERSION=0.8.1.1)	22 Oct 2015 03:29PM UTC	87.27	Travis Job 729.9
10	729.10 (KAFKA_VERSION=0.8.2.1)	22 Oct 2015 03:28PM UTC	87.11	Travis Job 729.10
11	729.11 (UNIT_AND_LINT_ONLY=true)	22 Oct 2015 03:25PM UTC	66.72	Travis Job 729.11
12	729.12 (KAFKA_VERSION=0.8.0)	22 Oct 2015 03:31PM UTC	82.45	Travis Job 729.12
13	729.13 (KAFKA_VERSION=0.8.1)	22 Oct 2015 03:32PM UTC	87.42	Travis Job 729.13
14	729.14 (KAFKA_VERSION=0.8.1.1)	22 Oct 2015 03:34PM UTC	87.42	Travis Job 729.14
15	729.15 (KAFKA_VERSION=0.8.2.1)	22 Oct 2015 03:35PM UTC	87.16	Travis Job 729.15
16	729.16 (UNIT_AND_LINT_ONLY=true)	22 Oct 2015 03:31PM UTC	66.77	Travis Job 729.16
17	729.17 (KAFKA_VERSION=0.8.0)	22 Oct 2015 03:37PM UTC	82.45	Travis Job 729.17
18	729.18 (KAFKA_VERSION=0.8.1)	22 Oct 2015 03:37PM UTC	87.62	Travis Job 729.18
19	729.19 (KAFKA_VERSION=0.8.1.1)	22 Oct 2015 03:39PM UTC	87.37	Travis Job 729.19
20	729.20 (KAFKA_VERSION=0.8.2.1)	22 Oct 2015 03:40PM UTC	87.21	Travis Job 729.20
21	729.21 (UNIT_AND_LINT_ONLY=true)	22 Oct 2015 03:39PM UTC	66.41	Travis Job 729.21
22	729.22 (KAFKA_VERSION=0.8.0)	22 Oct 2015 03:44PM UTC	82.6	Travis Job 729.22
23	729.23 (KAFKA_VERSION=0.8.1)	22 Oct 2015 03:43PM UTC	87.06	Travis Job 729.23
24	729.24 (KAFKA_VERSION=0.8.1.1)	22 Oct 2015 03:45PM UTC	87.37	Travis Job 729.24
25	729.25 (KAFKA_VERSION=0.8.2.1)	22 Oct 2015 03:45PM UTC	87.16	Travis Job 729.25

Source Files on build 729

Detailed source file information is not available for this build.

mumrah / kafka-python / 729
88%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Uncovered Existing Lines

Jobs

Source Files on build 729

mumrah / kafka-python / 729 88%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Uncovered Existing Lines

Jobs

Source Files on build 729

mumrah / kafka-python / 729
88%

README BADGES
x