kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Weide Zhang <weo...@gmail.com>
Subject offset commit api
Date Sun, 03 Aug 2014 23:34:43 GMT

I'm reading the offset management on the API link.

I have a couple of questions regarding using the offset fetch and commit
API in ?

1. Is the new offset commit and fetch api usable in use in ?  Does already support offset coordinator ?

2. what's the difference between old offsetrequest and new
offsetfetchrequest ? It seems to me that the new api support per consumer
group offset management fetch while old api doesn't. Also, what's the
purpose of using a timestamp parameter in the fetch request ?

3. In, the OffsetCommitRequest uses OffsetMetadataAndError, could
you tell me what's the purpose of the error parameter and metadata
parameter in the request ?

4. Can I assume the offset management is purely independent of message
consumption ? In other words, if I use a simple consumer to fetch message
with random client id, can I still manually set some consumer group along
with offset in the offset commit message ? Is that allowed ?



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