STORM-2607: Storm-kafka-client never commits the last message on a partition. - #2367

Merged

asfgit merged 2 commits into

apache:masterfrom

srdo:STORM-2607-fixup

Oct 14, 2017

Commits on Oct 11, 2017

[STORM-2607] Offset consumer + 1

Rodolfo Ribeiro
authored and
srdo
committed
STORM-2607: Switch OffsetManager to track earliest uncommitted offset instead of last committed offset for compatibility with commitSync consumer API
srdo
committed