kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stevo Slavić <ssla...@gmail.com>
Subject New consumer - ConsumerRecords partitions
Date Tue, 21 Jul 2015 09:27:43 GMT
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.

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