kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From James Cheng <jch...@tivo.com>
Subject Checkpointing with custom metadata
Date Mon, 03 Aug 2015 20:52:22 GMT
According to https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommitRequest,
we can store custom metadata with our checkpoints. It looks like the high level consumer does
not support committing offsets with metadata, and that in order to checkpoint with custom
metadata, we have to issue the OffsetCommitRequest ourselves. Is that correct?


  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message