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
...@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
@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
, 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
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
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
@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
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
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