Hi It seems to me that 0.8.1.1 doesn't have the ConsumerMetadata API. So what broker I should choose in order to commit and fetch offset information ? Shall I use zookeeper for offset to manage it manually instead ?
Thanks, Weide On Sun, Aug 3, 2014 at 4:34 PM, Weide Zhang <weo...@gmail.com> wrote: > Hi, > > I'm reading the offset management on the API link. > > https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-OffsetCommit/FetchAPI > > I have a couple of questions regarding using the offset fetch and commit > API in 0.8.1.1 ? > > 1. Is the new offset commit and fetch api usable in use in 0.8.1.1 ? Does > 0.8.1.1 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 0.8.1.1, 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 ? > > Thanks, > > Weide > >
