[jira] [Updated] (KAFKA-12515) ApiVersionManager should create response based on request version

[ https://issues.apache.org/jira/browse/KAFKA-12515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-12515: --- Description: *Background:* Currently, `ApiVersionManager` generates `ApiVersionResponse` without consideri

[jira] [Updated] (KAFKA-12515) ApiVersionManager should create response based on request version

[ https://issues.apache.org/jira/browse/KAFKA-12515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-12515: --- Description: *Background:* Currently, `ApiVersionManager` generates `ApiVersionResponse` without consideri

[jira] [Created] (KAFKA-12515) ApiVersionManager should create response based on request version

feyman created KAFKA-12515: -- Summary: ApiVersionManager should create response based on request version Key: KAFKA-12515 URL: https://issues.apache.org/jira/browse/KAFKA-12515 Project: Kafka Issue

[jira] [Comment Edited] (KAFKA-9689) Automatic broker version detection to initialize stream client

[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272901#comment-17272901 ] feyman edited comment on KAFKA-9689 at 1/28/21, 3:54 AM: - The ver

[jira] [Comment Edited] (KAFKA-9689) Automatic broker version detection to initialize stream client

[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272901#comment-17272901 ] feyman edited comment on KAFKA-9689 at 1/27/21, 2:57 PM: - The ver

[jira] [Commented] (KAFKA-9689) Automatic broker version detection to initialize stream client

[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17272901#comment-17272901 ] feyman commented on KAFKA-9689: --- The version detection flow leveraging the versioning syste

[jira] [Commented] (KAFKA-9689) Automatic broker version detection to initialize stream client

[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17253798#comment-17253798 ] feyman commented on KAFKA-9689: --- Checked with [~bchen225242] offline, I will pick up this t

[jira] [Assigned] (KAFKA-9689) Automatic broker version detection to initialize stream client

[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman reassigned KAFKA-9689: - Assignee: feyman (was: HaiyuanZhao) > Automatic broker version detection to initialize stream client >

[jira] [Commented] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248766#comment-17248766 ] feyman commented on KAFKA-10636: [~hachikuji] I created a PR for this, request for revie

[jira] [Comment Edited] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248766#comment-17248766 ] feyman edited comment on KAFKA-10636 at 12/14/20, 7:01 AM: --- [~

[jira] [Comment Edited] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248766#comment-17248766 ] feyman edited comment on KAFKA-10636 at 12/14/20, 7:01 AM: --- [~

[jira] [Commented] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243646#comment-17243646 ] feyman commented on KAFKA-10636: [~hachikuji]  Cool, thanks for the help! > Bypass log

[jira] [Commented] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242122#comment-17242122 ] feyman commented on KAFKA-10636: Hi, [~hachikuji] . I would like to take this task, plea

[jira] [Assigned] (KAFKA-10636) Bypass log validation for writes to raft log

[ https://issues.apache.org/jira/browse/KAFKA-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman reassigned KAFKA-10636: -- Assignee: feyman > Bypass log validation for writes to raft log > ---

[jira] [Commented] (KAFKA-9876) Implement Raft Protocol for Metadata Quorum

[ https://issues.apache.org/jira/browse/KAFKA-9876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234299#comment-17234299 ] feyman commented on KAFKA-9876: --- Hi, [~hachikuji], I'm interested in Raft and also KIP-595,

[jira] [Commented] (KAFKA-9755) Implement versioning scheme for features

[ https://issues.apache.org/jira/browse/KAFKA-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17219553#comment-17219553 ] feyman commented on KAFKA-9755: --- Hi, [~kprakasam], can I take sub-task 7/8 as start-up task

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17192885#comment-17192885 ] feyman commented on KAFKA-10284: Just FYI, created a PR: https://github.com/apache/kafka

[jira] [Updated] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-10284: --- Attachment: How to reproduce the issue in KAFKA-10284.md > Group membership update due to static member rejo

[jira] [Commented] (KAFKA-10284) Group membership update due to static member rejoin should be persisted

[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17182608#comment-17182608 ] feyman commented on KAFKA-10284: Checked with [~bchen225242] offline, and I just reprodu

[jira] [Comment Edited] (KAFKA-10307) Topology cycles in KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178234#comment-17178234 ] feyman edited comment on KAFKA-10307 at 8/15/20, 11:40 AM: --- Hi

[jira] [Commented] (KAFKA-10307) Topology cycles in KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17178234#comment-17178234 ] feyman commented on KAFKA-10307: Hi, [~vvcephei] I just verified with the latest trunk b

[jira] [Commented] (KAFKA-10307) Topology cycles in KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176796#comment-17176796 ] feyman commented on KAFKA-10307: Hi, [~vvcephei] I'm running with the trunk branch but

[jira] [Commented] (KAFKA-10307) Topology cycles in KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176224#comment-17176224 ] feyman commented on KAFKA-10307: [~vvcephei] Thanks for letting me know that we can have

[jira] [Updated] (KAFKA-10307) Topology cycles in KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable

[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-10307: --- Attachment: repartition_calc.jpg > Topology cycles in > KTableKTableForeignKeyInnerJoinMultiIntegrationTest

[jira] [Assigned] (KAFKA-10135) Extract Task#executeAndMaybeSwallow to be a general utility function into TaskManager

[ https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman reassigned KAFKA-10135: -- Assignee: feyman > Extract Task#executeAndMaybeSwallow to be a general utility function into > TaskM

[jira] [Commented] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17128366#comment-17128366 ] feyman commented on KAFKA-9377: --- [~bchen225242] Created a PR [https://github.com/apache/kaf

[jira] [Commented] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126442#comment-17126442 ] feyman commented on KAFKA-9377: --- [~bchen225242], I'm very glad to take it and even feel exc

[jira] [Comment Edited] (KAFKA-9377) Refactor StreamsPartitionAssignor Repartition Count logic

[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126442#comment-17126442 ] feyman edited comment on KAFKA-9377 at 6/5/20, 6:28 AM: [~bchen22

[jira] [Commented] (KAFKA-10097) Avoid getting null map for task checkpoint

[ https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126244#comment-17126244 ] feyman commented on KAFKA-10097: Cool, thanks a lot! [~bchen225242] > Avoid getting nul

[jira] [Commented] (KAFKA-10097) Avoid getting null map for task checkpoint

[ https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17125652#comment-17125652 ] feyman commented on KAFKA-10097: Hi, [~bchen225242], I'm interested in kafka streams and

[jira] [Closed] (KAFKA-10064) Add documentation for KIP-571

[ https://issues.apache.org/jira/browse/KAFKA-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman closed KAFKA-10064. -- > Add documentation for KIP-571 > - > > Key: KAFKA-10064 >

[jira] [Commented] (KAFKA-10064) Add documentation for KIP-571

[ https://issues.apache.org/jira/browse/KAFKA-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120240#comment-17120240 ] feyman commented on KAFKA-10064: [~bchen225242], create a PR for this as in the issue li

[jira] [Comment Edited] (KAFKA-10064) Add documentation for KIP-571

[ https://issues.apache.org/jira/browse/KAFKA-10064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17120240#comment-17120240 ] feyman edited comment on KAFKA-10064 at 5/30/20, 12:50 PM: --- [~

[jira] [Updated] (KAFKA-10035) Improve the AbstractResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-10035: --- Description: In the test: AbstractResetIntegrationTest, there are several places like below:   {code:java}

[jira] [Updated] (KAFKA-10035) Improve the AbstractResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-10035: --- Labels: (was: newbie) > Improve the AbstractResetIntegrationTest > ---

[jira] [Updated] (KAFKA-10035) Improve the AbstractResetIntegrationTest

[ https://issues.apache.org/jira/browse/KAFKA-10035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] feyman updated KAFKA-10035: --- Labels: newbie (was: ) > Improve the AbstractResetIntegrationTest > ---

[jira] [Created] (KAFKA-10035) Improve the AbstractResetIntegrationTest

feyman created KAFKA-10035: -- Summary: Improve the AbstractResetIntegrationTest Key: KAFKA-10035 URL: https://issues.apache.org/jira/browse/KAFKA-10035 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17096347#comment-17096347 ] feyman commented on KAFKA-9146: --- Hi, I have created a new PR and request for review, thanks

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028823#comment-17028823 ] feyman commented on KAFKA-9146: --- Thanks for your comments, this is very helpful ! [~bchen22

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17027258#comment-17027258 ] feyman commented on KAFKA-9146: --- Hi, [~bchen225242], [~mjsax], I have created a PR for this

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17006658#comment-17006658 ] feyman commented on KAFKA-9146: --- Hi, [~mjsax] I checked the code again with your guidance,

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998987#comment-16998987 ] feyman commented on KAFKA-9146: --- Thanks, [~mjsax] ! This is very helpful !  > Add option

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997961#comment-16997961 ] feyman commented on KAFKA-9146: --- [~bchen225242] , [~mjsax]  I have briefly went through the

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974856#comment-16974856 ] feyman commented on KAFKA-9146: --- Thanks , [~mjsax] ! If it do imply a public API change an

[jira] [Commented] (KAFKA-9146) Add option to force delete members in stream reset tool

[ https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974762#comment-16974762 ] feyman commented on KAFKA-9146: --- Hi, I would like to contribute to kafka and take this task