[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] [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: KAFKA-94

[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&focusedCommentId=17042817#comment-17042817 ] Boyang Chen commented on KAFKA-9592: [~guozhang] [~hachikuji] Do you mind taking a lo

[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&focusedCommentId=17042819#comment-17042819 ] Boyang Chen commented on KAFKA-9592: [~iamabug] I will assign this ticket to you for

[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-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&focusedCommentId=17043162#comment-17043162 ] Boyang Chen commented on KAFKA-9398: Looks like the patch is closed atm > Kafka Stre

[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&focusedCommentId=17043163#comment-17043163 ] Boyang Chen commented on KAFKA-6435: This is very an interesting scenario. However we

[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 t

[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] [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&focusedCommentId=17043717#comment-17043717 ] Boyang Chen commented on KAFKA-9562: A status update: we have fixed two sub tasks and

[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] [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 I

[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&focusedCommentId=17044693#comment-17044693 ] Boyang Chen commented on KAFKA-9562: We are soaking the 2.5 with/without EOS for anot

[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] [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 cou

[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 comple

[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] [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&focusedCommentId=17044899#comment-17044899 ] Boyang Chen commented on KAFKA-9118: [~viktorsomogyi] Hey Viktor, do you have time to

[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 Re

[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&focusedCommentId=17044956#comment-17044956 ] Boyang Chen commented on KAFKA-8458: h3. Error Message org.junit.ComparisonFailure:

[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 (w

[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} [2020-02-25T

[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 Is

[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 exceptio

[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} [2020-02-25T08:

[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 o

[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} [2020-02-25T08:

[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&focusedCommentId=17045789#comment-17045789 ] Boyang Chen commented on KAFKA-9118: [~viktorsomogyi] Look forward to it! Just to cla

[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 Issu

[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 Is

[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&focusedCommentId=17047122#comment-17047122 ] Boyang Chen commented on KAFKA-9592: Thanks for taking a look [~iamabug] ! Feel free

[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&focusedCommentId=17047203#comment-17047203 ] Boyang Chen commented on KAFKA-8460: Test failed again:  {code:java} Error Messageorg

[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&focusedCommentId=17047813#comment-17047813 ] Boyang Chen commented on KAFKA-9618: Reproduced the exception as: {code:java} [stream

[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&focusedCommentId=17048449#comment-17048449 ] Boyang Chen commented on KAFKA-9618: The root cause was that we were releasing the st

[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&focusedCommentId=17047813#comment-17047813 ] Boyang Chen edited comment on KAFKA-9618 at 3/1/20 2:15 AM: R

[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: Improve

[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&focusedCommentId=17050469#comment-17050469 ] Boyang Chen commented on KAFKA-9638: Thanks for the ticket. Could you provide a more

[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&focusedCommentId=17050496#comment-17050496 ] Boyang Chen commented on KAFKA-9118: [~viktorsomogyi] Thanks for the info. Did you al

[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: Bug

[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: Sub-task

[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 re

[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] [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 b

[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] [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-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-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 Iss

[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] [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-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 > bra

[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&focusedCommentId=17056193#comment-17056193 ] Boyang Chen commented on KAFKA-9562: >From the soak result we could close this ticket

[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] [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&focusedCommentId=17056670#comment-17056670 ] Boyang Chen commented on KAFKA-9701: Reproduced on trunk as well: ``` [2020-03-10T20

[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: Ka

[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] [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 cli

[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 Projec

[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&focusedCommentId=17059069#comment-17059069 ] Boyang Chen commented on KAFKA-9568: The current design of static membership will not

[jira] [Assigned] (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:all-tabpanel ] Boyang Chen reassigned KAFKA-9568: -- Assignee: Sophie Blee-Goldman > Kstreams APPLICATION_SERVER_CONFIG is not updated with static

[jira] [Commented] (KAFKA-9722) Kafka stops consuming messages after error

2020-03-14 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059444#comment-17059444 ] Boyang Chen commented on KAFKA-9722: Could you summarize the error in your descriptio

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

2020-03-15 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17059716#comment-17059716 ] Boyang Chen commented on KAFKA-9679: Thanks for taking this up! [~sujayopensource] Ye

[jira] [Created] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

2020-03-16 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9727: -- Summary: Flaky system test StreamsEOSTest.test_failure_and_recovery Key: KAFKA-9727 URL: https://issues.apache.org/jira/browse/KAFKA-9727 Project: Kafka Issue Ty

[jira] [Commented] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

2020-03-18 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17062005#comment-17062005 ] Boyang Chen commented on KAFKA-8122: Failed again  [https://builds.apache.org/job/ka

[jira] [Reopened] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

2020-03-18 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reopened KAFKA-8122: Assignee: (was: Matthias J. Sax) > Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTask

[jira] [Updated] (KAFKA-9705) Config changes should be propagated from Controller in bridge release

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9705: --- Summary: Config changes should be propagated from Controller in bridge release (was: (Incremental)Al

[jira] [Resolved] (KAFKA-9727) Flaky system test StreamsEOSTest.test_failure_and_recovery

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9727?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9727. Resolution: Fixed > Flaky system test StreamsEOSTest.test_failure_and_recovery > --

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

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Description: The bug was due to an out-of-order handling of the SyncGroupRequest after the LeaveGrou

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

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9701: -- Assignee: Boyang Chen > Consumer could catch InconsistentGroupProtocolException during rebalan

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

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Description: The bug was due to an out-of-order handling of the SyncGroupRequest after the LeaveGrou

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

2020-03-20 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9701: --- Priority: Blocker (was: Major) > Consumer could catch InconsistentGroupProtocolException during reba

[jira] [Created] (KAFKA-9743) StreamTask could fail to close during HandleNewAssignment

2020-03-21 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9743: -- Summary: StreamTask could fail to close during HandleNewAssignment Key: KAFKA-9743 URL: https://issues.apache.org/jira/browse/KAFKA-9743 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-9751) Admin `FindCoordinator` call should go to controller instead of ZK

2020-03-23 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9751: -- Summary: Admin `FindCoordinator` call should go to controller instead of ZK Key: KAFKA-9751 URL: https://issues.apache.org/jira/browse/KAFKA-9751 Project: Kafka

[jira] [Resolved] (KAFKA-8230) Add static membership support in librd consumer client

2020-03-23 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8230. Resolution: Fixed Will be tracked on the librdKafka side, which seems to be done > Add static memb

[jira] [Resolved] (KAFKA-9743) StreamTask could fail to close during HandleNewAssignment

2020-03-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9743. Resolution: Fixed > StreamTask could fail to close during HandleNewAssignment > ---

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

2020-03-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9475. Resolution: Won't Fix It seems not worth the effort as we could just shrink the scheduler time > R

[jira] [Created] (KAFKA-9757) Add documentation change for KIP-535

2020-03-24 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9757: -- Summary: Add documentation change for KIP-535 Key: KAFKA-9757 URL: https://issues.apache.org/jira/browse/KAFKA-9757 Project: Kafka Issue Type: Sub-task Affec

[jira] [Assigned] (KAFKA-9758) Add documentations for Streams release

2020-03-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9758: -- Assignee: Boyang Chen > Add documentations for Streams release > -

[jira] [Created] (KAFKA-9758) Add documentations for Streams release

2020-03-24 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9758: -- Summary: Add documentations for Streams release Key: KAFKA-9758 URL: https://issues.apache.org/jira/browse/KAFKA-9758 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-9758) Add documentations for Streams release

2020-03-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9758: --- Description: This ticket tracks the doc updates for a couple of KIPs launched in stream 2.5, includi

[jira] [Assigned] (KAFKA-9759) Add documentation change for KIP-562

2020-03-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9759: -- Assignee: Vinoth Chandar > Add documentation change for KIP-562 >

[jira] [Created] (KAFKA-9759) Add documentation change for KIP-562

2020-03-24 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9759: -- Summary: Add documentation change for KIP-562 Key: KAFKA-9759 URL: https://issues.apache.org/jira/browse/KAFKA-9759 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-9758) Add documentations for KIP-523 and KIP-527

2020-03-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9758: --- Description: As titled, tracking doc changes for 523 and 527 launched in stream 2.5. (was: This tick

[jira] [Created] (KAFKA-9760) Add EOS protocol changes to documentation

2020-03-24 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9760: -- Summary: Add EOS protocol changes to documentation Key: KAFKA-9760 URL: https://issues.apache.org/jira/browse/KAFKA-9760 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-9764) Deprecate Stream Simple benchmark

2020-03-25 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9764: -- Summary: Deprecate Stream Simple benchmark Key: KAFKA-9764 URL: https://issues.apache.org/jira/browse/KAFKA-9764 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9772) Transactional offset commit fails with IllegalStateException

2020-03-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17068343#comment-17068343 ] Boyang Chen commented on KAFKA-9772: Could we attach the full log here? > Transactio

[jira] [Created] (KAFKA-9779) Add version 2.5 to streams system tests

2020-03-27 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9779: -- Summary: Add version 2.5 to streams system tests Key: KAFKA-9779 URL: https://issues.apache.org/jira/browse/KAFKA-9779 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-9784) Add OffsetFetch to the concurrent coordinator test

2020-03-28 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-9784: -- Summary: Add OffsetFetch to the concurrent coordinator test Key: KAFKA-9784 URL: https://issues.apache.org/jira/browse/KAFKA-9784 Project: Kafka Issue Type: Impr

[jira] [Assigned] (KAFKA-9759) Add documentation change for KIP-562

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9759: -- Assignee: Navinder Brar (was: Vinoth Chandar) > Add documentation change for KIP-562 > --

[jira] [Assigned] (KAFKA-9759) Add documentation change for KIP-562

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9759: -- Assignee: Boyang Chen (was: Navinder Brar) > Add documentation change for KIP-562 > -

[jira] [Commented] (KAFKA-9757) Add documentation change for KIP-535

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071067#comment-17071067 ] Boyang Chen commented on KAFKA-9757: I'm not sure how to configure this, but let's sa

[jira] [Updated] (KAFKA-9757) Add documentation change for KIP-535

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9757: --- Due Date: 1/Apr/20 > Add documentation change for KIP-535 > > >

[jira] [Commented] (KAFKA-9759) Add documentation change for KIP-562

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071115#comment-17071115 ] Boyang Chen commented on KAFKA-9759: [~vinoth] sg, I will do this one myself just to

[jira] [Assigned] (KAFKA-8870) Prevent dirty reads of Streams state store from Interactive queries

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8870: -- Assignee: Boyang Chen > Prevent dirty reads of Streams state store from Interactive queries >

[jira] [Commented] (KAFKA-8677) Flakey test GroupEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

2020-03-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8677?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17071393#comment-17071393 ] Boyang Chen commented on KAFKA-8677: This also happens for trunk, FYI:  [2020-03-30T

[jira] [Updated] (KAFKA-9776) Producer should automatically downgrade TxnOffsetCommitRequest

2020-03-31 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Affects Version/s: (was: 2.5.0) 2.6.0 > Producer should automatically down

[jira] [Updated] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

2020-03-31 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Summary: Producer could automatically downgrade TxnOffsetCommitRequest with internal flag (was: Prod

[jira] [Updated] (KAFKA-9776) Producer could automatically downgrade TxnOffsetCommitRequest with internal flag

2020-03-31 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9776: --- Parent: KAFKA-8587 Issue Type: Sub-task (was: Improvement) > Producer could automatically do

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