Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Gwen Shapira
Subject: Add missing API to old high level consumer Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer that commits offsets using a user provided offset map. public void commitOffsets(MapTopicPartition

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Joe Stein
...@linkedin.com Date: Tuesday, May 12, 2015 at 4:51 PM To: dev@kafka.apache.orgmailto:dev@kafka.apache.org dev@kafka.apache.orgmailto:dev@kafka.apache.org Subject: Add missing API to old high level consumer Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Gwen Shapira
@kafka.apache.org Subject: Add missing API to old high level consumer Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer that commits offsets using a user provided offset map. public

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Jun Rao
, 2015 at 4:51 PM To: dev@kafka.apache.orgmailto:dev@kafka.apache.org dev@kafka.apache.orgmailto:dev@kafka.apache.org Subject: Add missing API to old high level consumer Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-15 Thread Jiangjie Qin
to the email title : ) From: Jiangjie Qin j...@linkedin.commailto:j...@linkedin.com Date: Tuesday, May 12, 2015 at 4:51 PM To: dev@kafka.apache.orgmailto:dev@kafka.apache.org dev@kafka.apache.orgmailto:dev@kafka.apache.org Subject: Add missing API to old high level consumer Hi, I just noticed

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-14 Thread Jiangjie Qin
title : ) From: Jiangjie Qin j...@linkedin.commailto:j...@linkedin.com Date: Tuesday, May 12, 2015 at 4:51 PM To: dev@kafka.apache.orgmailto:dev@kafka.apache.org dev@kafka.apache.orgmailto:dev@kafka.apache.org Subject: Add missing API to old high level consumer Hi, I just noticed

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-14 Thread Joe Stein
@kafka.apache.org dev@kafka.apache.orgmailto:dev@kafka.apache.org Subject: Add missing API to old high level consumer Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer that commits offsets using a user provided offset map

Re: [DISCUSS] Add missing API to old high level consumer

2015-05-13 Thread Joe Stein
Subject: Add missing API to old high level consumer Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer that commits offsets using a user provided offset map. public void commitOffsets(MapTopicPartition, OffsetAndMetadata

Add missing API to old high level consumer

2015-05-12 Thread Jiangjie Qin
Hi, I just noticed that in KAFKA-1650 (which is before we use KIP) we added an offset commit method in high level consumer that commits offsets using a user provided offset map. public void commitOffsets(MapTopicPartition, OffsetAndMetadata offsetsToCommit, boolean retryOnFailure); This