Hi Sean / Andrew / Lianet,

Thanks for all your review and suggestions.

AS1, LM1, LM4: Change to add KIP-848 information when users give —verbose 
option.
—describe —verbose: shows group epoch and target assignment epoch.
—describe —members —verbose: shows above information, member epoch, and target 
assignment.

AS2: Change to use MEMBER-EPOCH to align with KIP-848 definition.

LM2: For classic group, it doesn’t have epoch, so I use Optional fields in 
ConsumerGroupDescription.
For share group, it relies on KIP-848. It must have epoch, so I use int fields 
in ShareGroupDescription.

LM3: Remove —state change. We can get group level information by —describe 
—verbose.

SQ1: Add LEADER-EPOCH when users give —describe —offsets —verbose.

Thanks.
PoAn

> On Nov 1, 2024, at 5:08 AM, Lianet M. <liane...@gmail.com> wrote:
> 
> Hello Frank, thanks for the KIP! A few comments:
> 
> LM1. I strongly agree with Andrew's suggestion of moving this into a
> --verbose option. I expect someone would only attempt to make sense of the
> epochs while debugging an issue, not while trying to view the group or
> member's info. (Also member-epoch makes more sense to me, even more if we
> end up agreeing in a --verbose). Related to both issues, my take is that
> whoever is close to the protocol will expect member-epoch, whoever is not
> will probably won't even need to see the epochs at all.
> 
> LM2. Why are the epochs defined as Optional (don't we expect to always have
> them? with 0 initially, defined on the broker side for the group ones, and
> client side for the member)
> 
> LM3. Why is the KIP including the –state option in the proposed changes? (
> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=327977411#KIP1099:Extendkafkaconsumergroupscommandlinetooltosupportnewconsumergroup---state
> ).
> I get that the output would change in that example, but it’s not because of
> any change to the –state option itself. It's because of the change proposed
> to the –described (required with the --state), and the changes to
> --describe are already explained above (seems confusing, got me looking for
> a change to the state filter which seemed unrelated).
> 
> LM4. Group epoch and target assignment epoch are conceptually at the group
> level. vs member epoch that lands at a member level. So wonder if we should
> show them accordingly (ex. using the --verbose option)
>  –describe –verbose => shows group epoch and target assignment epoch
>                –describe –members –verbose => shows member epoch (along
> with group epoch and target assignment epoch)
> 
> Thanks!
> 
> Lianet
> 
> On Thu, Oct 31, 2024 at 7:30 AM Andrew Schofield <
> andrew_schofield_j...@outlook.com> wrote:
> 
>> Hi PoAn,
>> Thanks for the KIP. I have a few comments.
>> 
>> AS1: It seems to me that these new additions are most useful to people
>> trying to understand
>> the progress of rebalancing in quite some detail. The information is
>> really not understandable
>> for most users who do not have deep knowledge of KIP-848/932.
>> 
>> As a result, I suggest for kafka-share-groups.sh that you add a --members
>> --verbose option
>> and only include the new information in the output for that option, rather
>> than changing the
>> non-verbose --members output.
>> 
>> I also make a similar suggestion for kafka-consumer-groups.sh --members
>> and only add the
>> new information for the --verbose output.
>> 
>> AS2: I strongly suggest that you use MEMBER-EPOCH instead of
>> CONSUMER-EPOCH.
>> I think it's more confusing not following the terminology of the KIPs. For
>> one thing,
>> we already have "member" in the admin client such as MemberDescription.
>> It's not a
>> new term.
>> 
>> 
>> Thanks,
>> Andrew
>> ________________________________________
>> From: PoAn Yang <pay...@apache.org>
>> Sent: 25 October 2024 13:55
>> To: dev@kafka.apache.org <dev@kafka.apache.org>
>> Subject: Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line
>> tool to support new consumer group
>> 
>> Hi Lucas,
>> 
>> Thanks for the review!
>> 
>> 1) Yes, I add related change for kafka-share-groups.sh to the KIP. Could
>> you take a look? Thanks for the suggestion.
>> 
>> 2) We use CONSUMER-ID as member ID. If we use MEMBER-EPOCH here, users may
>> confuse what is different between CONSUMER and MEMBER.
>> 
>> Thanks,
>> PoAn
>> 
>> On 2024/10/23 13:28:17 Lucas Brutschy wrote:
>>> Hi Frank,
>>> 
>>> thanks for the KIP!
>>> 
>>> 1) For consistency, should we do the same for
>>> kafka-share-groups.sh, ShareGroupDescription, etc. ? Even if we do not
>>> implement it right now if the share group implementation may still be
>>> incomplete, it may make sense to include it in the KIP.
>>> 
>>> 2) Why call it CONSUMER-EPOCH, not MEMBER-EPOCH? That would seem more
>>> consistent.
>>> 
>>> Cheers,
>>> Lucas
>>> 
>>> On Wed, Oct 23, 2024 at 2:41 PM Frank Yang <yangp...@gmail.com> wrote:
>>> 
>>>> Hi all,
>>>> 
>>>> I would like to kick off the discussion of KIP-1099. This KIP enhances
>> the
>>>> kafka-consumer-groups tools to include state which is introduced by
>> KIP-848.
>>>> 
>>>> KIP-1099: Extend kafka-consumer-groups command line tool to support new
>>>> consumer group - Apache Kafka - Apache Software Foundation
>>>> <
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1099%3A+Extend+kafka-consumer-groups+command+line+tool+to+support+new+consumer+group
>>> 
>>>> cwiki.apache.org
>>>> <
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1099%3A+Extend+kafka-consumer-groups+command+line+tool+to+support+new+consumer+group
>>> 
>>>> [image: favicon.ico]
>>>> <
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1099%3A+Extend+kafka-consumer-groups+command+line+tool+to+support+new+consumer+group
>>> 
>>>> <
>> https://cwiki.apache.org/confluence/display/KAFKA/KIP-1099%3A+Extend+kafka-consumer-groups+command+line+tool+to+support+new+consumer+group
>>> 
>>>> 
>>>> Thank you,
>>>> PoAn
>>>> 
>>> 
>> 

Reply via email to