THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
- Changing the
DescribeGroups
protocol so it also returns the offset information for all topic partitions from which the group has consumed from since its creation. More detailed can be found here. - Exposing the added
OffsetFetch
behavior through a new interface inKafkaConsumer
, which would still imply that the dummy consumer has to be created in the group in order to retrieve offsets. More details can be found here. - Passing an empty list, instead of
null
, to the API to get all offsets. Thenull
value was chosen to remain consistent with how some other APIs handle a similar situation (e.g.TopicMetadata
request provides API returns metadata of all topics if it is provided with anull
value as list of topics).