Hi Michał,
Internally, Kafka uses "*consumer group ID*" as the key to decide which
__consumer_offsets partition to be used.
The code is like this:
`Utils.abs(groupId.hashCode) % groupMetadataTopicPartitionCount`
You can check the `partitionFor` method in GroupMetadataManager class.
Hope that hel
Hey,
Could someone please point me to the code / doc where I can find
information what is used as key and how messages are spread across
partitions for this internal topic?
--
BR,
Michał Łowicki
[You are receiving this email because you are subscribed to the user
list of one or more Apache project.]
Dear Apache enthusiast,
ApacheCon is our annual convention, featuring content related to our
many software projects. This year, it will be held on September 21-23.
Registration is free t
