[
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
[
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
[
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
[
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
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
[
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
> -
[
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
> --
[
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
[
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
> -
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
[
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
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
[
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
[
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
[
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
> ---
[
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
> -
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
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
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
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
[
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
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
[
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
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
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
[
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
[
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
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
[
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
[
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
[
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
[
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
> ---
[
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
[
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
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
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
[
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
[
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:
[
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
[
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:
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
[
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
[
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
[
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
[
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:
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
[
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
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
[
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
[
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
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
[
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
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
[
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
> --
[
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
[
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
> -
[
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
[
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
[
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
[
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
[
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
> -
[
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
[
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
[
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
>
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
Iss
[
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
> ---
[
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
>
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
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040402#comment-17040402
]
Boyang Chen commented on KAFKA-9568:
I guess the purpose here was to trigger an expli
[
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 ti
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
[
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
> st
[
https://issues.apache.org/jira/browse/KAFKA-9439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039588#comment-17039588
]
Boyang Chen commented on KAFKA-9439:
[~iamabug] Sorry for late reply, this ticket see
[
https://issues.apache.org/jira/browse/KAFKA-9568?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039505#comment-17039505
]
Boyang Chen commented on KAFKA-9568:
Thanks for reporting this, I'm not sure I fully
[
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`
> --
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 Type
[
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:
[2020-02-12T07:14:35-0
[
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}
[2020-02-
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
[
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 `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDele
[
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
>
[
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
>
[
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 queue
[
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 mode
[
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
> -
[
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
> --
[
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
`FENCED_LEADER_
[
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 update
[
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 `FENCED_LEADER_E
[
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 `FENCED_LEADER_E
[
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 upd
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
[
https://issues.apache.org/jira/browse/KAFKA-9534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17033997#comment-17033997
]
Boyang Chen commented on KAFKA-9534:
The reproduction is not very consistent, will ta
[
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 scrip
[
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 reques
[
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: Pote
[
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 BranchedMultiLevelRepartitionConnectedTopologyTest
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
401 - 500 of 958 matches
Mail list logo