[jira] [Updated] (KAFKA-10181) AlterConfig/IncrementalAlterConfig should go to controller

2020-06-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10181: Component/s: admin > AlterConfig/IncrementalAlterConfig should go to controller >

[jira] [Commented] (KAFKA-10158) Fix flaky kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

2020-06-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147967#comment-17147967 ] Boyang Chen commented on KAFKA-10158: - failed again: 

[jira] [Updated] (KAFKA-10216) Loosen permission for listing reassignments

2020-06-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10216?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10216: Component/s: core > Loosen permission for listing reassignments >

[jira] [Commented] (KAFKA-10185) Streams should log summarized restoration information at info level

2020-06-18 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139955#comment-17139955 ] Boyang Chen commented on KAFKA-10185: - Could we add the context to this ticket? > Streams should

[jira] [Updated] (KAFKA-9439) Add more public API tests for KafkaProducer

2020-06-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9439: --- Fix Version/s: 2.7.0 > Add more public API tests for KafkaProducer >

[jira] [Commented] (KAFKA-9509) Fix flaky test MirrorConnectorsIntegrationTest.testReplication

2020-06-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143314#comment-17143314 ] Boyang Chen commented on KAFKA-9509: Failed again: h3. Stacktrace java.lang.RuntimeException: Could

[jira] [Resolved] (KAFKA-10087) Properly throw LogTruncation exception from OffsetForLeaderEpoch future

2020-06-17 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10087. - Resolution: Fixed > Properly throw LogTruncation exception from OffsetForLeaderEpoch future >

[jira] [Created] (KAFKA-10181) AlterConfig/IncrementalAlterConfig should go to controller

2020-06-17 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10181: --- Summary: AlterConfig/IncrementalAlterConfig should go to controller Key: KAFKA-10181 URL: https://issues.apache.org/jira/browse/KAFKA-10181 Project: Kafka

[jira] [Updated] (KAFKA-9989) Wait for stable assignment StreamsUpgradeTest.test_metadata_upgrade

2020-06-15 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9989: --- Summary: Wait for stable assignment StreamsUpgradeTest.test_metadata_upgrade (was:

[jira] [Updated] (KAFKA-9989) Wait for stable assignment StreamsUpgradeTest.test_metadata_upgrade

2020-06-15 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9989: --- Description: After some discussion we believe there is room to improve the accuracy of this test,

[jira] [Commented] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

2020-06-07 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127684#comment-17127684 ] Boyang Chen commented on KAFKA-6435: [~JoelWee] Thanks for your interest! Feel free to take it, but

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

2020-06-09 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10135: --- Summary: Extract Task#executeAndMaybeSwallow to be a general utility function into TaskManager Key: KAFKA-10135 URL: https://issues.apache.org/jira/browse/KAFKA-10135

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

2020-06-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10135: Component/s: streams > Extract Task#executeAndMaybeSwallow to be a general utility function into

[jira] [Created] (KAFKA-10139) Add operational guide for failure recovery

2020-06-10 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10139: --- Summary: Add operational guide for failure recovery Key: KAFKA-10139 URL: https://issues.apache.org/jira/browse/KAFKA-10139 Project: Kafka Issue Type:

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

2020-06-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126001#comment-17126001 ] Boyang Chen commented on KAFKA-10097: - [~feyman] Thank you for the interest! Unfortunately this

[jira] [Resolved] (KAFKA-9576) Topic creation failure causing Stream thread death

2020-06-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9576. Resolution: Duplicate > Topic creation failure causing Stream thread death >

[jira] [Updated] (KAFKA-10097) Avoid passing task checkpoint file externally

2020-06-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10097: Summary: Avoid passing task checkpoint file externally (was: Avoid getting null map for task

[jira] [Resolved] (KAFKA-10097) Avoid passing task checkpoint file externally

2020-06-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10097?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10097. - Resolution: Fixed > Avoid passing task checkpoint file externally >

[jira] [Commented] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

2020-06-07 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17127880#comment-17127880 ] Boyang Chen commented on KAFKA-6435: I would prefer we reach agreement on the approach here, before

[jira] [Commented] (KAFKA-6435) Application Reset Tool might delete incorrect internal topics

2020-06-08 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17128656#comment-17128656 ] Boyang Chen commented on KAFKA-6435: Thanks for confirming! [~JoelWee] Do you think our discussion

[jira] [Updated] (KAFKA-10126) Remove unused options in ConsumerPerformance

2020-06-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Component/s: tools consumer > Remove unused options in ConsumerPerformance >

[jira] [Updated] (KAFKA-10126) Remove unused options in ConsumerPerformance

2020-06-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Issue Type: Improvement (was: Bug) > Remove unused options in ConsumerPerformance >

[jira] [Commented] (KAFKA-10126) Remove unused options in ConsumerPerformance

2020-06-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17129615#comment-17129615 ] Boyang Chen commented on KAFKA-10126: - I don't think we could remove options unless in a breaking

[jira] [Created] (KAFKA-10130) Rewrite ZkData struct with auto-generated protocol

2020-06-09 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10130: --- Summary: Rewrite ZkData struct with auto-generated protocol Key: KAFKA-10130 URL: https://issues.apache.org/jira/browse/KAFKA-10130 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-10130) Rewrite ZkData struct with auto-generated protocol

2020-06-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10130: Component/s: protocol core > Rewrite ZkData struct with auto-generated protocol

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

2020-06-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126166#comment-17126166 ] Boyang Chen commented on KAFKA-9377: [~feyman] Hey I'm assigning this ticket to you. A little bit

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

2020-06-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9377: -- Assignee: feyman (was: Boyang Chen) > Refactor StreamsPartitionAssignor Repartition Count

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

2020-06-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10097: --- Summary: Avoid getting null map for task checkpoint Key: KAFKA-10097 URL: https://issues.apache.org/jira/browse/KAFKA-10097 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

2020-06-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17125457#comment-17125457 ] Boyang Chen commented on KAFKA-9891: [~mateuszjadczyk] I see, glad you guys have a workaround. I

[jira] [Commented] (KAFKA-9891) Invalid state store content after task migration with exactly_once and standby replicas

2020-06-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124296#comment-17124296 ] Boyang Chen commented on KAFKA-9891: [~mateuszjadczyk] that's right, so we should only check

[jira] [Updated] (KAFKA-10087) Properly throw LogTruncation exception from OffsetForLeaderEpoch future

2020-06-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10087: Description: For OffsetForLeaderEpoch#onSuccess, we could throw either OffsetOutOfRange or

[jira] [Created] (KAFKA-10087) Properly throw LogTruncation exception from OffsetForLeaderEpoch future

2020-06-02 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10087: --- Summary: Properly throw LogTruncation exception from OffsetForLeaderEpoch future Key: KAFKA-10087 URL: https://issues.apache.org/jira/browse/KAFKA-10087 Project: Kafka

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

2020-06-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126890#comment-17126890 ] Boyang Chen commented on KAFKA-9377: [~feyman] np, take your time! > Refactor

[jira] [Commented] (KAFKA-9953) support multiple consumerGroupCoordinators in TransactionManager

2020-06-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17135011#comment-17135011 ] Boyang Chen commented on KAFKA-9953: Thanks for reporting the use case [~jwijgerd] . At a minimum,

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

2020-07-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10307: --- Summary: Topology cycles in KTableKTableForeignKeyInnerJoinMultiIntegrationTest#shouldInnerJoinMultiPartitionQueryable Key: KAFKA-10307 URL:

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

2020-07-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17164760#comment-17164760 ] Boyang Chen commented on KAFKA-10307: - [~vvcephei] Could you take a look? [~feyman] found this out

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

2020-07-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10307: Component/s: streams > Topology cycles in >

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

2020-07-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10307: Affects Version/s: 2.6.0 2.4.0 2.5.0 > Topology

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

2020-07-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10307: Priority: Major (was: Minor) > Topology cycles in >

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

2020-07-17 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160216#comment-17160216 ] Boyang Chen commented on KAFKA-10284: - If we have a combined scenario like below: # A static

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

2020-07-17 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17160216#comment-17160216 ] Boyang Chen edited comment on KAFKA-10284 at 7/17/20, 10:28 PM: If we

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

2020-07-17 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10284: Description: For known static members rejoin, we would update its corresponding member.id

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

2020-07-28 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166681#comment-17166681 ] Boyang Chen commented on KAFKA-10284: - That's a good observation, I forgot that for static members

[jira] [Created] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionWhileRunning would block forever on JDK11

2020-07-29 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10321: --- Summary: shouldDieOnInvalidOffsetExceptionWhileRunning would block forever on JDK11 Key: KAFKA-10321 URL: https://issues.apache.org/jira/browse/KAFKA-10321 Project:

[jira] [Commented] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionDuringStartup would block forever on JDK11

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166928#comment-17166928 ] Boyang Chen commented on KAFKA-10321: - Actually I think I found the bug, check out the PR here: 

[jira] [Commented] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionWhileRunning would block forever on JDK11

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166909#comment-17166909 ] Boyang Chen commented on KAFKA-10321: - Looks like we have an infinite blocking logic in

[jira] [Updated] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionDuringStartup would block forever on JDK11

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10321: Summary: shouldDieOnInvalidOffsetExceptionDuringStartup would block forever on JDK11 (was:

[jira] [Updated] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionDuringStartup would block forever on JDK11

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10321: Description: Have spotted two definite cases where the test 

[jira] [Commented] (KAFKA-10321) shouldDieOnInvalidOffsetExceptionWhileRunning would block forever on JDK11

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166911#comment-17166911 ] Boyang Chen commented on KAFKA-10321: - cc [~mjsax] [~vvcephei] who added this test in the PR: 

[jira] [Created] (KAFKA-10311) Flaky test KafkaAdminClientTest#testMetadataRetries

2020-07-26 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10311: --- Summary: Flaky test KafkaAdminClientTest#testMetadataRetries Key: KAFKA-10311 URL: https://issues.apache.org/jira/browse/KAFKA-10311 Project: Kafka Issue

[jira] [Updated] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

2020-07-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10309: Component/s: streams > KafkaProducer's sendOffsetsToTransaction should not block infinitively >

[jira] [Updated] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

2020-07-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10309: Fix Version/s: 2.6.1 2.5.2 > KafkaProducer's sendOffsetsToTransaction should

[jira] [Commented] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

2020-07-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17165375#comment-17165375 ] Boyang Chen commented on KAFKA-10309: - Thanks for the proposal, I think this generally makes sense,

[jira] [Commented] (KAFKA-10309) KafkaProducer's sendOffsetsToTransaction should not block infinitively

2020-07-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17166151#comment-17166151 ] Boyang Chen commented on KAFKA-10309: - Sounds good. > KafkaProducer's sendOffsetsToTransaction

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

2020-07-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17163871#comment-17163871 ] Boyang Chen commented on KAFKA-10284: - [~akshaysh] I didn't see any trace that the group coordinator

[jira] [Updated] (KAFKA-10181) Redirect AlterConfig/IncrementalAlterConfig to the controller

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10181: Description: In the new Admin client, the AlterConfig/IncrementalAlterConfig request should be

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

2020-07-16 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10284: --- Summary: Group membership update due to static member rejoin should be persisted Key: KAFKA-10284 URL: https://issues.apache.org/jira/browse/KAFKA-10284 Project: Kafka

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

2020-07-16 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17159616#comment-17159616 ] Boyang Chen commented on KAFKA-10284: -

[jira] [Created] (KAFKA-10241) Pursue a better way to cover ignorable RPC fields

2020-07-06 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10241: --- Summary: Pursue a better way to cover ignorable RPC fields Key: KAFKA-10241 URL: https://issues.apache.org/jira/browse/KAFKA-10241 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10813) StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in all cases

2020-12-04 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10813: --- Summary: StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in all cases Key: KAFKA-10813 URL: https://issues.apache.org/jira/browse/KAFKA-10813

[jira] [Assigned] (KAFKA-10813) StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in all cases

2020-12-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10813: --- Assignee: Boyang Chen > StreamsProducer should catch InvalidProducerEpoch and throw

[jira] [Updated] (KAFKA-10345) Add file-watch based update for trust/key store paths

2020-12-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Description: With forwarding enabled, per-broker alter-config doesn't go to the target broker

[jira] [Updated] (KAFKA-10345) Add file-watch based update for trust/key store paths

2020-12-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Summary: Add file-watch based update for trust/key store paths (was: Add ZK-notification based

[jira] [Created] (KAFKA-10807) AlterConfig should be validated by the target broker

2020-12-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10807: --- Summary: AlterConfig should be validated by the target broker Key: KAFKA-10807 URL: https://issues.apache.org/jira/browse/KAFKA-10807 Project: Kafka Issue

[jira] [Updated] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2020-11-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10733: Labels: need-kip (was: ) > Enforce exception thrown for KafkaProducer txn APIs >

[jira] [Commented] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2020-11-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237765#comment-17237765 ] Boyang Chen commented on KAFKA-10733: - Also we should understand why we see a trend of seeing more

[jira] [Updated] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2020-11-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10733: Affects Version/s: 2.7.0 2.5.0 2.6.0 > Enforce

[jira] [Updated] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2020-11-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10733: Component/s: streams producer > Enforce exception thrown for KafkaProducer txn

[jira] [Commented] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2020-11-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17237764#comment-17237764 ] Boyang Chen commented on KAFKA-10733: - Several agreements being made on offline sync: 1. We

[jira] [Resolved] (KAFKA-9552) Stream should handle OutOfSequence exception thrown from Producer

2020-12-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9552. Resolution: Not A Problem > Stream should handle OutOfSequence exception thrown from Producer >

[jira] [Resolved] (KAFKA-10813) StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in all cases

2020-12-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10813. - Resolution: Fixed > StreamsProducer should catch InvalidProducerEpoch and throw TaskMigrated in

[jira] [Updated] (KAFKA-10345) Add file-watch based update for trust/key store paths

2020-12-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Description: With forwarding enabled, per-broker alter-config doesn't go to the target broker

[jira] [Updated] (KAFKA-10345) Add auto reloading for trust/key store paths

2020-12-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Summary: Add auto reloading for trust/key store paths (was: Add file-watch based update for

[jira] [Created] (KAFKA-10868) Avoid double wrapping KafkaException

2020-12-18 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10868: --- Summary: Avoid double wrapping KafkaException Key: KAFKA-10868 URL: https://issues.apache.org/jira/browse/KAFKA-10868 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-10868) Avoid double wrapping KafkaException

2020-12-18 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10868: Description: Today certain exceptions get double wraps of KafkaException. We should remove those

[jira] [Updated] (KAFKA-10346) Propagate topic creation policy violation to the clients

2020-11-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10346?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10346: Description: At the moment, topic creation policy is not enforced on auto topic creation path for

[jira] [Updated] (KAFKA-9751) Auto topic creation should go to controller

2020-11-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9751: --- Summary: Auto topic creation should go to controller (was: Internal topic creation should go to

[jira] [Updated] (KAFKA-10350) Add forwarding request monitoring metrics

2020-11-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10350: Summary: Add forwarding request monitoring metrics (was: Add redirect request monitoring

[jira] [Created] (KAFKA-10714) Save unnecessary end txn call when the transaction is confirmed to be done

2020-11-12 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10714: --- Summary: Save unnecessary end txn call when the transaction is confirmed to be done Key: KAFKA-10714 URL: https://issues.apache.org/jira/browse/KAFKA-10714 Project:

[jira] [Assigned] (KAFKA-10674) Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding

2020-11-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10674: --- Assignee: Boyang Chen > Brokers should know the active controller ApiVersion after

[jira] [Assigned] (KAFKA-10655) Raft leader should resign after write failures

2020-11-17 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10655: --- Assignee: Boyang Chen (was: Jason Gustafson) > Raft leader should resign after write

[jira] [Created] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2020-11-17 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10733: --- Summary: Enforce exception thrown for KafkaProducer txn APIs Key: KAFKA-10733 URL: https://issues.apache.org/jira/browse/KAFKA-10733 Project: Kafka Issue

[jira] [Created] (KAFKA-10699) Add system test coverage for group coordinator emigration

2020-11-08 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10699: --- Summary: Add system test coverage for group coordinator emigration Key: KAFKA-10699 URL: https://issues.apache.org/jira/browse/KAFKA-10699 Project: Kafka

[jira] [Assigned] (KAFKA-10699) Add system test coverage for group coordinator emigration

2020-11-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10699: --- Assignee: feyman > Add system test coverage for group coordinator emigration >

[jira] [Updated] (KAFKA-10347) Deprecate Metadata ControllerId

2020-11-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10347: Summary: Deprecate Metadata ControllerId (was: Redirect Create/DeleteTopics to the controller)

[jira] [Updated] (KAFKA-10347) Deprecate Metadata ControllerId

2020-11-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10347: Description: When forwarding is enabled, we should not let client know the active controller

[jira] [Assigned] (KAFKA-9751) Internal topic creation should go to controller

2020-11-09 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9751: -- Assignee: Boyang Chen > Internal topic creation should go to controller >

[jira] [Created] (KAFKA-10674) Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding

2020-11-02 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10674: --- Summary: Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding Key: KAFKA-10674 URL: https://issues.apache.org/jira/browse/KAFKA-10674

[jira] [Assigned] (KAFKA-10342) Migrate remaining RPCs to forward to the controller

2020-11-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10342: --- Assignee: Boyang Chen > Migrate remaining RPCs to forward to the controller >

[jira] [Updated] (KAFKA-10342) Migrate remaining RPCs to forward to the controller

2020-11-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Summary: Migrate remaining RPCs to forward to the controller (was: Redirect remaining RPCs to

[jira] [Updated] (KAFKA-10342) Redirect remaining RPCs to the controller

2020-11-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Description: This ticket tracks the progress along migrating the rest of RPCs to the controller

[jira] [Updated] (KAFKA-10342) Redirect remaining RPCs to the controller

2020-11-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Summary: Redirect remaining RPCs to the controller (was: Redirect Create/DeleteAcls to the

[jira] [Resolved] (KAFKA-10343) Add IBP based ApiVersion constraint tests

2020-11-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10343. - Resolution: Won't Fix We are planning to work on a more long-term fix for this issue, see  >

[jira] [Comment Edited] (KAFKA-10343) Add IBP based ApiVersion constraint tests

2020-11-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17225029#comment-17225029 ] Boyang Chen edited comment on KAFKA-10343 at 11/3/20, 12:32 AM: We are

[jira] [Updated] (KAFKA-10345) Add ZK-notification based update for trust/key store paths

2020-11-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Fix Version/s: 2.8.0 > Add ZK-notification based update for trust/key store paths >

[jira] [Updated] (KAFKA-10345) Add ZK-notification based update for trust/key store paths

2020-11-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Description: With forwarding enabled, per-broker alter-config doesn't go to the target broker

[jira] [Assigned] (KAFKA-10345) Add ZK-notification based update for trust/key store paths

2020-11-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10345: --- Assignee: Boyang Chen > Add ZK-notification based update for trust/key store paths >

[jira] [Updated] (KAFKA-10345) Add ZK-notification based update for trust/key store paths

2020-11-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Summary: Add ZK-notification based update for trust/key store paths (was: Redirect

[jira] [Created] (KAFKA-10657) Incorporate Envelope into auto-generated JSON schema

2020-10-28 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10657: --- Summary: Incorporate Envelope into auto-generated JSON schema Key: KAFKA-10657 URL: https://issues.apache.org/jira/browse/KAFKA-10657 Project: Kafka Issue

[jira] [Updated] (KAFKA-10657) Incorporate Envelope into auto-generated JSON schema

2020-10-28 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10657: Description: We need to add support to output JSON format for embed request inside Envelope to

<    4   5   6   7   8   9   10   >