Siyuan,
In general 0.9 new consumer API relies on the group coordinator on the
broker side to manage consumer groups, so you would need to upgrade the
brokers first.
However if you are only using the assign() function to assign partitions,
i.e. no subscribe() which will not need the group coordinator, the consumer
should work with an older broker version.
Guozhang
On Mon, Nov 30, 2015 at 12:58 PM, Wang, Howard <howard.w...@washpost.com>
wrote:
> Thanks.
>
> I just found the new KafkaConsumer does have two API functions
> assignment() and
> committed(TopicPartition partition). With these 2 functions, we¹ll be able
> to retrieve the timestamp of last offset regardless whether offset storage
> is using ZK or offset topic.
>
> Howard
>
>
>
> --
> Howard Wang
> Engineering Big Data and Personalization
> Washington Post Media
>
>
> 1150 15th St NW, Washington, DC 20071
> p. 202-334-9195
> Email: howard.w...@washpost.com
>
>
>
>
>
> On 11/30/15, 3:55 PM, "hsy...@gmail.com" <hsy...@gmail.com> wrote:
>
> >Is 0.9 new consumer API compatible with 0.8.x.x broker
>
>
--
-- Guozhang
