flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Renjie Liu <liurenjie2...@gmail.com>
Subject Kafka 09 consumer does not commit offsets
Date Mon, 09 Jan 2017 10:51:59 GMT
Hi, all:
I'm using flink 1.1.3 and kafka consumer 09. I read its code and it says
that the kafka consumer will turn on auto offset commit if checkpoint is
not enabled. I've turned off checkpoint and it seems that kafka client is
not committing to offsets to kafka? The offset is important for helping us
monitoring. Anyone has encountered this before?
-- 
Liu, Renjie
Software Engineer, MVAD

Mime
View raw message