View Issue Details

Jump to NotesJump to History
IDProjectCategoryView StatusDate SubmittedLast Update
0000011KafkaEsqueImprovementpublic2018-11-25 22:452018-12-13 18:53
ReporterOliver G.Assigned Topatschuh 
PrioritynormalSeverityfeatureReproducibilityhave not tried
Status resolvedResolutionno change required 
Product Version 
Target Version0.12.0Fixed in Version0.12.0 
Summary0000011: Fix consumer indefinite blocking behaviour
Description

Use poll(Duration) instead of poll(long), but be aware to add some timeout instead of 0 (long).

https://cwiki.apache.org/confluence/display/KAFKA/KIP-266%3A+Fix+consumer+indefinite+blocking+behavior

TagsNo tags attached.

Relationships

duplicate of 0000014 resolvedpatschuh Add option for trace start position 

Activities

patschuh

patschuh

2018-11-26 17:04

developer   ~0000010

Last edited: 2018-11-27 06:10

View 3 revisions

Looking at the KafkaConsumercode in 2.0 it seems more reliable to use position(TopicPartion, Duration) or just position(TopicPartition)instead of poll(Duration), because according to the JavaDoc position(TopicPartition) actually throws a TimeoutException if the position cannot be determined before the passed timeout expires.
patschuh

patschuh

2018-12-13 18:53

developer   ~0000017

should be fixed with consumer handling rework in 0000014

Issue History

Date Modified Username Field Change
2018-11-25 22:45 Oliver G. New Issue
2018-11-26 06:39 patschuh Target Version => 0.12.0
2018-11-26 17:04 patschuh Note Added: 0000010
2018-11-26 17:05 patschuh Note Edited: 0000010 View Revisions
2018-11-27 06:10 patschuh Note Edited: 0000010 View Revisions
2018-12-13 18:53 patschuh Assigned To => patschuh
2018-12-13 18:53 patschuh Status new => resolved
2018-12-13 18:53 patschuh Resolution open => no change required
2018-12-13 18:53 patschuh Fixed in Version => 0.12.0
2018-12-13 18:53 patschuh Note Added: 0000017
2018-12-13 18:53 patschuh Relationship added duplicate of 0000014