kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stevo Slavić <ssla...@gmail.com>
Subject Re: New consumer - ConsumerRecords partitions
Date Wed, 22 Jul 2015 13:36:43 GMT
Hello Jason,

Thanks for feedback. I've created JIRA ticket for feature request:
https://issues.apache.org/jira/browse/KAFKA-2356

Kind regards,
Stevo Slavic.

On Tue, Jul 21, 2015 at 6:17 PM, Jason Gustafson <jason@confluent.io> wrote:

> Hey Stevo,
>
> I think ConsumerRecords only contains the partitions which had messages.
> Would you mind creating a jira for the feature request? You're welcome to
> submit a patch as well.
>
> -Jason
>
> On Tue, Jul 21, 2015 at 2:27 AM, Stevo Slavić <sslavic@gmail.com> wrote:
>
> > Hello Apache Kafka community,
> >
> > New HLC poll returns ConsumerRecords.
> >
> > Do ConsumerRecords contain records for every partition that HLC is
> actively
> > subscribed on for every poll request, or does it contain only records for
> > partitions which had messages and which were retrieved in poll request?
> >
> > If latter, then please consider adding a method to ConsumerRecords class,
> > "public Iterable<TopicPartition> getPartitions()" that the
> ConsumerRecords
> > has. I could provide a PR.
> >
> > Kind regards,
> > Stevo Slavic.
> >
>

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