kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jason Gustafson <ja...@confluent.io>
Subject Re: New consumer - ConsumerRecords partitions
Date Tue, 21 Jul 2015 16:17:14 GMT
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