[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059069#comment-17059069 ] Boyang Chen commented on KAFKA-9568: The current design of static membership will not kick-off

[jira] [Created] (KAFKA-9719) Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade

2020-03-13 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9719: -- Summary: Add Integration Test For ensuring the EOS-beta app would crash with broker downgrade Key: KAFKA-9719 URL: https://issues.apache.org/jira/browse/KAFKA-9719

[jira] [Assigned] (KAFKA-9657) Add configurable throw on unsupported protocol

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9657: -- Assignee: Boyang Chen > Add configurable throw on unsupported protocol >

[jira] [Resolved] (KAFKA-9657) Add configurable throw on unsupported protocol

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9657. Resolution: Fixed > Add configurable throw on unsupported protocol >

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

2020-03-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9689: -- Assignee: (was: Boyang Chen) > Automatic broker version detection to initialize stream

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

2020-03-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9689: -- Assignee: Boyang Chen > Automatic broker version detection to initialize stream client >

[jira] [Created] (KAFKA-9705) (Incremental)AlterConfig should be propagated from Controller in bridge release

2020-03-11 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9705: -- Summary: (Incremental)AlterConfig should be propagated from Controller in bridge release Key: KAFKA-9705 URL: https://issues.apache.org/jira/browse/KAFKA-9705 Project:

[jira] [Commented] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056670#comment-17056670 ] Boyang Chen commented on KAFKA-9701: Reproduced on trunk as well: ``` [2020-03-10T20:05:27-07:00]

[jira] [Created] (KAFKA-9701) Consumer could catch InconsistentGroupProtocolException during rebalance

2020-03-10 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9701: -- Summary: Consumer could catch InconsistentGroupProtocolException during rebalance Key: KAFKA-9701 URL: https://issues.apache.org/jira/browse/KAFKA-9701 Project: Kafka

[jira] [Resolved] (KAFKA-9562) Streams not making progress under heavy failures with EOS enabled on 2.5 branch

2020-03-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9562. Resolution: Fixed > Streams not making progress under heavy failures with EOS enabled on 2.5 >

[jira] [Commented] (KAFKA-9562) Streams not making progress under heavy failures with EOS enabled on 2.5 branch

2020-03-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056193#comment-17056193 ] Boyang Chen commented on KAFKA-9562: >From the soak result we could close this ticket for now >

[jira] [Resolved] (KAFKA-9618) Failed state store deletion could lead to task file not found

2020-03-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9618. Resolution: Fixed > Failed state store deletion could lead to task file not found >

[jira] [Resolved] (KAFKA-9674) Task corruption should also close the producer if necessary

2020-03-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9674. Resolution: Fixed > Task corruption should also close the producer if necessary >

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

2020-03-09 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9689: -- Summary: Automatic broker version detection to initialize stream client Key: KAFKA-9689 URL: https://issues.apache.org/jira/browse/KAFKA-9689 Project: Kafka

[jira] [Created] (KAFKA-9679) Mock consumer should behave consistent with actual consumer

2020-03-06 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9679: -- Summary: Mock consumer should behave consistent with actual consumer Key: KAFKA-9679 URL: https://issues.apache.org/jira/browse/KAFKA-9679 Project: Kafka Issue

[jira] [Created] (KAFKA-9676) Add test coverage for new ActiveTaskCreator and StandbyTaskCreator

2020-03-06 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9676: -- Summary: Add test coverage for new ActiveTaskCreator and StandbyTaskCreator Key: KAFKA-9676 URL: https://issues.apache.org/jira/browse/KAFKA-9676 Project: Kafka

[jira] [Created] (KAFKA-9674) Task corruption should also close the producer if necessary

2020-03-06 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9674: -- Summary: Task corruption should also close the producer if necessary Key: KAFKA-9674 URL: https://issues.apache.org/jira/browse/KAFKA-9674 Project: Kafka Issue

[jira] [Updated] (KAFKA-9666) Transactional producer Epoch could not be reset

2020-03-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9666: --- Description: As of today, the producer epoch keeps increasing until it hits Short.Max. The correct

[jira] [Created] (KAFKA-9666) Transactional producer Epoch could not be reset

2020-03-05 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9666: -- Summary: Transactional producer Epoch could not be reset Key: KAFKA-9666 URL: https://issues.apache.org/jira/browse/KAFKA-9666 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-9656) TxnOffsetCommit should not return COORDINATOR_LOADING error for old request versions

2020-03-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9656: -- Assignee: Boyang Chen > TxnOffsetCommit should not return COORDINATOR_LOADING error for old

[jira] [Created] (KAFKA-9657) Add configurable throw on unsupported protocol

2020-03-04 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9657: -- Summary: Add configurable throw on unsupported protocol Key: KAFKA-9657 URL: https://issues.apache.org/jira/browse/KAFKA-9657 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9645) Records could not find corresponding partition/task

2020-03-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9645: -- Summary: Records could not find corresponding partition/task Key: KAFKA-9645 URL: https://issues.apache.org/jira/browse/KAFKA-9645 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

2020-03-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050496#comment-17050496 ] Boyang Chen commented on KAFKA-9118: [~viktorsomogyi] Thanks for the info. Did you already have a

[jira] [Commented] (KAFKA-9638) Do not trigger REBALANCING when specific exceptions occur in Kafka Streams

2020-03-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17050469#comment-17050469 ] Boyang Chen commented on KAFKA-9638: Thanks for the ticket. Could you provide a more detailed example

[jira] [Created] (KAFKA-9637) Create separate state directory to manage locks

2020-03-02 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9637: -- Summary: Create separate state directory to manage locks Key: KAFKA-9637 URL: https://issues.apache.org/jira/browse/KAFKA-9637 Project: Kafka Issue Type:

[jira] [Comment Edited] (KAFKA-9618) Failed state store deletion could lead to task file not found

2020-02-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047813#comment-17047813 ] Boyang Chen edited comment on KAFKA-9618 at 3/1/20 2:15 AM: Reproduced the

[jira] [Commented] (KAFKA-9618) Failed state store deletion could lead to task file not found

2020-02-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17048449#comment-17048449 ] Boyang Chen commented on KAFKA-9618: The root cause was that we were releasing the state store lock

[jira] [Commented] (KAFKA-9618) Failed state store deletion could lead to task file not found

2020-02-28 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047813#comment-17047813 ] Boyang Chen commented on KAFKA-9618: Reproduced the exception as: {code:java}

[jira] [Reopened] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2020-02-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-8460: > Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition >

[jira] [Commented] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2020-02-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047203#comment-17047203 ] Boyang Chen commented on KAFKA-8460: Test failed again:  {code:java} Error

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-02-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17047122#comment-17047122 ] Boyang Chen commented on KAFKA-9592: Thanks for taking a look [~iamabug] ! Feel free to take 5604 as

[jira] [Created] (KAFKA-9620) Task revocation failure could introduce remaining unclean tasks

2020-02-27 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9620: -- Summary: Task revocation failure could introduce remaining unclean tasks Key: KAFKA-9620 URL: https://issues.apache.org/jira/browse/KAFKA-9620 Project: Kafka

[jira] [Created] (KAFKA-9618) Failed state store deletion could lead to task file not found

2020-02-27 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9618: -- Summary: Failed state store deletion could lead to task file not found Key: KAFKA-9618 URL: https://issues.apache.org/jira/browse/KAFKA-9618 Project: Kafka

[jira] [Commented] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

2020-02-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17045789#comment-17045789 ] Boyang Chen commented on KAFKA-9118: [~viktorsomogyi] Look forward to it! Just to clarify, this PR is

[jira] [Updated] (KAFKA-9607) Should not clear partition queue during task close

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9607: --- Description: We detected an issue with a corrupted task failed to revive: {code:java}

[jira] [Updated] (KAFKA-9607) Should not clear partition queue during task close

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9607: --- Summary: Should not clear partition queue during task close (was: Should not clear partition queue

[jira] [Updated] (KAFKA-9607) Should not clear partition queue or throw illegal state exception during task revocation

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9607: --- Description: We detected an issue with a corrupted task failed to revive: {code:java}

[jira] [Created] (KAFKA-9610) Should not throw illegal state exception during task revocation

2020-02-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9610: -- Summary: Should not throw illegal state exception during task revocation Key: KAFKA-9610 URL: https://issues.apache.org/jira/browse/KAFKA-9610 Project: Kafka

[jira] [Updated] (KAFKA-9610) Should not throw illegal state exception during task revocation

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9610: --- Description: In handleRevocation call, the remaining partitions could cause an illegal state

[jira] [Updated] (KAFKA-9607) Should not clear partition queue or throw illegal state exception during task revocation

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9607: --- Description: 1. We detected an issue with a corrupted task failed to revive: {code:java}

[jira] [Updated] (KAFKA-9607) Should not clear partition queue or throw illegal state exception during task revocation

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9607: --- Summary: Should not clear partition queue or throw illegal state exception during task revocation

[jira] [Commented] (KAFKA-8458) Flaky Test AdminClientIntegrationTest#testElectPreferredLeaders

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044956#comment-17044956 ] Boyang Chen commented on KAFKA-8458: h3. Error Message org.junit.ComparisonFailure: expected:<...

[jira] [Created] (KAFKA-9608) An EOS model simulation test

2020-02-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9608: -- Summary: An EOS model simulation test Key: KAFKA-9608 URL: https://issues.apache.org/jira/browse/KAFKA-9608 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9118) LogDirFailureHandler shouldn't use Zookeeper

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044899#comment-17044899 ] Boyang Chen commented on KAFKA-9118: [~viktorsomogyi] Hey Viktor, do you have time to make progress

[jira] [Created] (KAFKA-9607) Should not clear partition group if the task will be revived again

2020-02-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9607: -- Summary: Should not clear partition group if the task will be revived again Key: KAFKA-9607 URL: https://issues.apache.org/jira/browse/KAFKA-9607 Project: Kafka

[jira] [Updated] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9605: --- Description: In the Producer we could see network client hits fatal exception while trying to

[jira] [Updated] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

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

[jira] [Created] (KAFKA-9605) EOS Producer could throw illegal state if trying to complete a failed batch after fatal error

2020-02-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9605: -- Summary: EOS Producer could throw illegal state if trying to complete a failed batch after fatal error Key: KAFKA-9605 URL: https://issues.apache.org/jira/browse/KAFKA-9605

[jira] [Commented] (KAFKA-9562) Streams not making progress under heavy failures with EOS enabled on 2.5 branch

2020-02-25 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044693#comment-17044693 ] Boyang Chen commented on KAFKA-9562: We are soaking the 2.5 with/without EOS for another 2 weeks to

[jira] [Created] (KAFKA-9602) Incorrect close of producer instance during partition assignment

2020-02-24 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9602: -- Summary: Incorrect close of producer instance during partition assignment Key: KAFKA-9602 URL: https://issues.apache.org/jira/browse/KAFKA-9602 Project: Kafka

[jira] [Assigned] (KAFKA-9600) EndTxn handler should check strict epoch equality

2020-02-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9600: -- Assignee: Boyang Chen > EndTxn handler should check strict epoch equality >

[jira] [Commented] (KAFKA-9562) Streams not making progress under heavy failures with EOS enabled on 2.5 branch

2020-02-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043717#comment-17043717 ] Boyang Chen commented on KAFKA-9562: A status update: we have fixed two sub tasks and one flush call

[jira] [Resolved] (KAFKA-9581) Deprecate rebalanceException on StreamThread to avoid infinite loop

2020-02-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9581. Resolution: Fixed > Deprecate rebalanceException on StreamThread to avoid infinite loop >

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

2020-02-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-6435: --- Labels: bug help-wanted newbie (was: bug) > Application Reset Tool might delete incorrect internal

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

2020-02-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043163#comment-17043163 ] Boyang Chen commented on KAFKA-6435: This is very an interesting scenario. However we currently have

[jira] [Commented] (KAFKA-9398) Kafka Streams main thread may not exit even after close timeout has passed

2020-02-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043162#comment-17043162 ] Boyang Chen commented on KAFKA-9398: Looks like the patch is closed atm > Kafka Streams main thread

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-02-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042819#comment-17042819 ] Boyang Chen commented on KAFKA-9592: [~iamabug] I will assign this ticket to you for now. Let's see

[jira] [Assigned] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-02-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9592: -- Assignee: Xiang Zhang > Safely abort Producer transactions during application shutdown >

[jira] [Commented] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-02-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042817#comment-17042817 ] Boyang Chen commented on KAFKA-9592: [~guozhang] [~hachikuji] Do you mind taking a look? > Safely

[jira] [Resolved] (KAFKA-9441) Refactor commit logic

2020-02-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9441. Resolution: Fixed > Refactor commit logic > - > > Key:

[jira] [Resolved] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

2020-02-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9582. Resolution: Fixed > Ensure EOS task producer not through fatal error in unclean shutdown >

[jira] [Created] (KAFKA-9592) Safely abort Producer transactions during application shutdown

2020-02-21 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9592: -- Summary: Safely abort Producer transactions during application shutdown Key: KAFKA-9592 URL: https://issues.apache.org/jira/browse/KAFKA-9592 Project: Kafka

[jira] [Updated] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

2020-02-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9582: --- Fix Version/s: 2.5.0 > Ensure EOS task producer not through fatal error in unclean shutdown >

[jira] [Assigned] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

2020-02-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9582: -- Assignee: Boyang Chen > Ensure EOS task producer not through fatal error in unclean shutdown

[jira] [Created] (KAFKA-9582) Ensure EOS task producer not through fatal error in unclean shutdown

2020-02-20 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9582: -- Summary: Ensure EOS task producer not through fatal error in unclean shutdown Key: KAFKA-9582 URL: https://issues.apache.org/jira/browse/KAFKA-9582 Project: Kafka

[jira] [Created] (KAFKA-9581) Deprecate rebalanceException on StreamThread to avoid infinite loop

2020-02-20 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9581: -- Summary: Deprecate rebalanceException on StreamThread to avoid infinite loop Key: KAFKA-9581 URL: https://issues.apache.org/jira/browse/KAFKA-9581 Project: Kafka

[jira] [Assigned] (KAFKA-9581) Deprecate rebalanceException on StreamThread to avoid infinite loop

2020-02-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9581: -- Assignee: Boyang Chen > Deprecate rebalanceException on StreamThread to avoid infinite loop >

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

2020-02-19 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9576: --- Description: The failure to create an internal topic could lead to the stream thread death due to

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

2020-02-19 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9576: -- Summary: Topic creation failure causing Stream thread death Key: KAFKA-9576 URL: https://issues.apache.org/jira/browse/KAFKA-9576 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-9473) A large number of core system tests failing due to Kafka server failed to start on trunk

2020-02-19 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9473. Resolution: Fixed > A large number of core system tests failing due to Kafka server failed to >

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

2020-02-18 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039588#comment-17039588 ] Boyang Chen commented on KAFKA-9439: [~iamabug] Sorry for late reply, this ticket seems to be taken

[jira] [Commented] (KAFKA-9568) Kstreams APPLICATION_SERVER_CONFIG is not updated with static membership

2020-02-18 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039505#comment-17039505 ] Boyang Chen commented on KAFKA-9568: Thanks for reporting this, I'm not sure I fully understood the

[jira] [Resolved] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

2020-02-16 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9545. Resolution: Fixed > Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` >

[jira] [Created] (KAFKA-9561) Update task input partitions when topic metadata changes

2020-02-14 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9561: -- Summary: Update task input partitions when topic metadata changes Key: KAFKA-9561 URL: https://issues.apache.org/jira/browse/KAFKA-9561 Project: Kafka Issue

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

2020-02-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9552: --- Description: As of today the stream thread could die from OutOfSequence error:

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

2020-02-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9552: --- Description: As of today the stream thread could die from OutOfSequence error: {code:java}

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

2020-02-13 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9552: -- Summary: Stream should handle OutOfSequence exception thrown from Producer Key: KAFKA-9552 URL: https://issues.apache.org/jira/browse/KAFKA-9552 Project: Kafka

[jira] [Assigned] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

2020-02-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9545: -- Assignee: Boyang Chen > Flaky Test

[jira] [Updated] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

2020-02-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9475: --- Labels: (was: help-wanted) > Replace transaction abortion scheduler with a delayed queue >

[jira] [Updated] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

2020-02-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9475: --- Labels: help-wanted (was: ) > Replace transaction abortion scheduler with a delayed queue >

[jira] [Assigned] (KAFKA-9475) Replace transaction abortion scheduler with a delayed queue

2020-02-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9475: -- Assignee: (was: Boyang Chen) > Replace transaction abortion scheduler with a delayed

[jira] [Updated] (KAFKA-9417) Integration test for new EOS model with vanilla Producer and Consumer

2020-02-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9417: --- Description: We would like to extend the `TransactionMessageCopier` to use the new subscription

[jira] [Resolved] (KAFKA-8616) Replace ApiVersionsRequest request/response with automated protocol

2020-02-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8616. Resolution: Duplicate > Replace ApiVersionsRequest request/response with automated protocol >

[jira] [Assigned] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

2020-02-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9535: -- Assignee: Boyang Chen > Metadata not updated when consumer encounters FENCED_LEADER_EPOCH >

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

2020-02-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9535: --- Description: Inside the consumer Fetcher's handling of ListOffsetResponse, if we hit

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9535: --- Summary: Metadata not updated when consumer encounters FENCED_LEADER_EPOCH (was: Metadata not

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters FENCED_LEADER_EPOCH

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9535: --- Description: Inside the consumer Fetcher's handling of ListOffsetResponse, if we hit

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters leader epoch related failures

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9535: --- Description: Inside the consumer Fetcher's handling of ListOffsetResponse, if we hit

[jira] [Updated] (KAFKA-9535) Metadata not updated when consumer encounters leader epoch related failures

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9535: --- Affects Version/s: 2.5.0 2.3.0 2.4.0 > Metadata not

[jira] [Created] (KAFKA-9535) Metadata not updated when consumer encounters leader epoch related failures

2020-02-10 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9535: -- Summary: Metadata not updated when consumer encounters leader epoch related failures Key: KAFKA-9535 URL: https://issues.apache.org/jira/browse/KAFKA-9535 Project: Kafka

[jira] [Commented] (KAFKA-9534) Topics could not be deleted when there is a concurrent create topic request loop

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033997#comment-17033997 ] Boyang Chen commented on KAFKA-9534: The reproduction is not very consistent, will take some time to

[jira] [Updated] (KAFKA-9534) Topics could not be deleted when there is a concurrent create topic request loop

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9534: --- Description: The reproduce steps: # start local ZK # start local broker #  Run the following

[jira] [Updated] (KAFKA-9534) Topics could not be deleted when there is a concurrent create topic request loop

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9534: --- Affects Version/s: 2.3.0 > Topics could not be deleted when there is a concurrent create topic

[jira] [Updated] (KAFKA-9534) Topics could not be deleted when there is a concurrent create topic request loop

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9534: --- Summary: Topics could not be deleted when there is a concurrent create topic request loop (was:

[jira] [Assigned] (KAFKA-9523) Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest

2020-02-10 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9523: -- Assignee: Boyang Chen > Reduce flakiness of

[jira] [Created] (KAFKA-9534) Potential inconsistent result for listTopic talking to older brokers

2020-02-10 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9534: -- Summary: Potential inconsistent result for listTopic talking to older brokers Key: KAFKA-9534 URL: https://issues.apache.org/jira/browse/KAFKA-9534 Project: Kafka

[jira] [Commented] (KAFKA-9525) Allow explicit rebalance triggering on the Consumer

2020-02-07 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032762#comment-17032762 ] Boyang Chen commented on KAFKA-9525: If you are talking about application level rebalance triggering,

[jira] [Created] (KAFKA-9523) Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest

2020-02-07 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9523: -- Summary: Reduce flakiness of BranchedMultiLevelRepartitionConnectedTopologyTest Key: KAFKA-9523 URL: https://issues.apache.org/jira/browse/KAFKA-9523 Project: Kafka

[jira] [Resolved] (KAFKA-9447) Add examples for EOS standalone and group mode under kafka/examples

2020-02-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9447. Resolution: Fixed > Add examples for EOS standalone and group mode under kafka/examples >

[jira] [Commented] (KAFKA-9487) Followup : KAFKA-9445

2020-02-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028677#comment-17028677 ] Boyang Chen commented on KAFKA-9487: Could we be more specific about the change in the ticket title? 

<    1   2   3   4   5   6   7   8   9   10   >