[
https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9868:
--
Assignee: Boyang Chen
> Flaky Test
> EOSUncleanShutdownIntegrationTest.shouldWorkWithUncleanS
[
https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9868:
---
Description:
h3. Error Message
java.lang.AssertionError: Condition not met within timeout 15000. Exp
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088086#comment-17088086
]
Boyang Chen commented on KAFKA-9882:
Thanks for the ticket. Are there any concrete us
[
https://issues.apache.org/jira/browse/KAFKA-9868?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088233#comment-17088233
]
Boyang Chen commented on KAFKA-9868:
[https://github.com/apache/kafka/pull/8522]
> F
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1708#comment-1708
]
Boyang Chen commented on KAFKA-9882:
I checked back on the original KIP
[https://cwi
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17088917#comment-17088917
]
Boyang Chen commented on KAFKA-9882:
I see, to make the discussion more effective, co
[
https://issues.apache.org/jira/browse/KAFKA-9882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17089006#comment-17089006
]
Boyang Chen commented on KAFKA-9882:
So you are trying to reset offset every time whe
Boyang Chen created KAFKA-9911:
--
Summary: Implement new producer fenced error
Key: KAFKA-9911
URL: https://issues.apache.org/jira/browse/KAFKA-9911
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-9910:
--
Summary: Implement new transaction timed out error
Key: KAFKA-9910
URL: https://issues.apache.org/jira/browse/KAFKA-9910
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17091804#comment-17091804
]
Boyang Chen commented on KAFKA-9913:
I'm fine with combining the two tickets in one K
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17092295#comment-17092295
]
Boyang Chen commented on KAFKA-9891:
I made a try to replicate the scenario with inte
[
https://issues.apache.org/jira/browse/KAFKA-9859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9859:
---
Labels: newbie newbie++ (was: )
> kafka-streams-application-reset tool doesn't take into account top
[
https://issues.apache.org/jira/browse/KAFKA-9921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17093773#comment-17093773
]
Boyang Chen commented on KAFKA-9921:
Hey [~georgi.petkov], would you mind explaining
[
https://issues.apache.org/jira/browse/KAFKA-8587?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8587.
Resolution: Fixed
> One producer per thread for Kafka Streams EOS
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9689:
---
Parent: (was: KAFKA-8587)
Issue Type: New Feature (was: Sub-task)
> Automatic broker ver
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17099547#comment-17099547
]
Boyang Chen commented on KAFKA-9453:
This could potentially simplify the setup for gr
[
https://issues.apache.org/jira/browse/KAFKA-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9454:
---
Parent: (was: KAFKA-8587)
Issue Type: Improvement (was: Sub-task)
> Relax transaction.id
[
https://issues.apache.org/jira/browse/KAFKA-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9454:
---
Component/s: streams
> Relax transaction.id security requirement
> --
[
https://issues.apache.org/jira/browse/KAFKA-9454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9454:
---
Labels: needs-kip (was: )
> Relax transaction.id security requirement
>
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Parent: (was: KAFKA-8587)
Issue Type: Improvement (was: Sub-task)
> Make transaction.id
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Labels: needs-kip (was: )
> Make transaction.id optional in group mode EOS
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9453:
---
Description:
After 447, one of the big improvement is that we are no longer requiring single
writer
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100020#comment-17100020
]
Boyang Chen commented on KAFKA-9891:
We had some offline discussion, and plan to revi
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100021#comment-17100021
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] on the other hand, if you are
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17100156#comment-17100156
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] Lol, no worry, thanks a lot fo
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17102271#comment-17102271
]
Boyang Chen commented on KAFKA-9891:
I don't see the full log for 3 nodes you mention
Boyang Chen created KAFKA-9972:
--
Summary: Corrupted standby task could be committed
Key: KAFKA-9972
URL: https://issues.apache.org/jira/browse/KAFKA-9972
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9878:
---
Summary: Block AddPartitionsToTxn call until the txn markers are committed
(was: Block EndTxn call u
Boyang Chen created KAFKA-9984:
--
Summary: Should fail the subscription when pattern is empty
Key: KAFKA-9984
URL: https://issues.apache.org/jira/browse/KAFKA-9984
Project: Kafka
Issue Type: Bug
[
https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106430#comment-17106430
]
Boyang Chen commented on KAFKA-8989:
Lost track, will close.
> Embedded broker could
[
https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-8989.
Resolution: Won't Fix
> Embedded broker could not be reached in unit test
> ---
Boyang Chen created KAFKA-9989:
--
Summary: StreamsUpgradeTest.test_metadata_upgrade could not
guarantee all processor gets assigned task
Key: KAFKA-9989
URL: https://issues.apache.org/jira/browse/KAFKA-9989
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106853#comment-17106853
]
Boyang Chen commented on KAFKA-9989:
Looks like it is determined by the assignor: (th
[
https://issues.apache.org/jira/browse/KAFKA-9984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106857#comment-17106857
]
Boyang Chen commented on KAFKA-9984:
[~guozhang] Thanks!
> Should fail the subscript
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17106950#comment-17106950
]
Boyang Chen commented on KAFKA-9989:
I didn't find that in the log [~ableegoldman]
>
[
https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-9676.
Resolution: Fixed
The current unit test coverage is pretty good now, closing the ticket.
> Add tes
Boyang Chen created KAFKA-9993:
--
Summary: Think about inheritance in the protocol generation
framework
Key: KAFKA-9993
URL: https://issues.apache.org/jira/browse/KAFKA-9993
Project: Kafka
Issue
Boyang Chen created KAFKA-9994:
--
Summary: Catch TaskMigrated exception in task corruption code path
Key: KAFKA-9994
URL: https://issues.apache.org/jira/browse/KAFKA-9994
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-9994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9994:
---
Description:
We have seen a case where the TaskMigrated exception gets thrown from
taskManager.commi
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9989:
--
Assignee: (was: Boyang Chen)
> StreamsUpgradeTest.test_metadata_upgrade could not guarante
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107623#comment-17107623
]
Boyang Chen commented on KAFKA-9989:
Discussed with [~cadonna] and it seems to be cau
Boyang Chen created KAFKA-:
--
Summary: Topic description should be triggered after each failed
topic creation iteration
Key: KAFKA-
URL: https://issues.apache.org/jira/browse/KAFKA-
Project:
[
https://issues.apache.org/jira/browse/KAFKA-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107672#comment-17107672
]
Boyang Chen commented on KAFKA-9676:
The current trunk has logic coverage for Standby
[
https://issues.apache.org/jira/browse/KAFKA-9993?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17107726#comment-17107726
]
Boyang Chen commented on KAFKA-9993:
Thanks [~vvcephei] An example is from the recent
[
https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7566.
Resolution: Won't Fix
> Add sidecar job to leader (or a random single follower) only
>
[
https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17108412#comment-17108412
]
Boyang Chen commented on KAFKA-9678:
[~m.sandeep] This ticket is already assigned, so
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-:
--
Assignee: Boyang Chen
> Topic description should be triggered after each failed topic creation
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-:
---
Summary: Internal topic creation failure should be non-fatal and trigger
explicit rebalance (was: T
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-:
---
Description:
We spotted a case in system test failure where the topic already exists but the
admin c
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-:
---
Description:
We spotted a case in system test failure where the topic already exists but the
admin c
Boyang Chen created KAFKA-10010:
---
Summary: Should close standby task for safety during HandleLostAll
Key: KAFKA-10010
URL: https://issues.apache.org/jira/browse/KAFKA-10010
Project: Kafka
Issue
Boyang Chen created KAFKA-10011:
---
Summary: lockedTaskDirectories should be cleared when task gets
closed dirty in HandleLostAll
Key: KAFKA-10011
URL: https://issues.apache.org/jira/browse/KAFKA-10011
Pr
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17109610#comment-17109610
]
Boyang Chen commented on KAFKA-10010:
-
The gain for keeping the standby task open is
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110636#comment-17110636
]
Boyang Chen commented on KAFKA-10010:
-
Had offline discussion with the team, so far
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17110638#comment-17110638
]
Boyang Chen commented on KAFKA-10010:
-
For more context, the
[reason|[https://githu
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10010:
Summary: Should make state store registration idempotent (was: Should
close standby task for safe
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
"Never saw outp
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9989:
--
Assignee: (was: Boyang Chen)
> StreamsUpgradeTest.test_metadata_upgrade could not guarante
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Labels: newbie (was: )
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Description:
System test StreamsUpgradeTest.test_metadata_upgrade could fail due to:
"Never saw outp
[
https://issues.apache.org/jira/browse/KAFKA-9989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9989:
---
Attachment: 166.tgz
> StreamsUpgradeTest.test_metadata_upgrade could not guarantee all processor
> g
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111343#comment-17111343
]
Boyang Chen commented on KAFKA-9891:
Sorry I was oncall last week. Will take another
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9878:
---
Description:
Currently the EndTxn call from Producer will immediately return as the control
record i
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114811#comment-17114811
]
Boyang Chen commented on KAFKA-9878:
Thanks for taking a look [~zhaohaidao], you are
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114811#comment-17114811
]
Boyang Chen edited comment on KAFKA-9878 at 5/23/20, 3:17 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17114862#comment-17114862
]
Boyang Chen commented on KAFKA-9891:
I made another attempt to reproduce the issue on
[
https://issues.apache.org/jira/browse/KAFKA-10036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10036:
Labels: newbie (was: )
> Improve error message is user violates `Supplier` pattern
>
[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10038:
Labels: newbie performance (was: performance)
> ConsumerPerformance.scala supports the setting of
[
https://issues.apache.org/jira/browse/KAFKA-10038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10038:
Component/s: consumer
> ConsumerPerformance.scala supports the setting of client.id
>
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9878:
---
Component/s: producer
core
> Block AddPartitionsToTxn call until the txn markers ar
Boyang Chen created KAFKA-10042:
---
Summary: Make INVALID_PRODUCER_EPOCH abortable from Produce
response
Key: KAFKA-10042
URL: https://issues.apache.org/jira/browse/KAFKA-10042
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-9146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9146:
---
Fix Version/s: 2.6.0
> Add option to force delete members in stream reset tool
>
[
https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-9561:
---
Fix Version/s: 2.6.0
> Update task input partitions when topic metadata changes
> ---
[
https://issues.apache.org/jira/browse/KAFKA-9878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-9878:
--
Assignee: HaiyuanZhao
> Block AddPartitionsToTxn call until the txn markers are committed
> --
Boyang Chen created KAFKA-10064:
---
Summary: Add documentation for KIP-571
Key: KAFKA-10064
URL: https://issues.apache.org/jira/browse/KAFKA-10064
Project: Kafka
Issue Type: Task
Compon
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17119899#comment-17119899
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] I ran your example again, and
[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10055:
Summary: Add shared internal utility class for Streams module (was: Add
shared internal utility c
[
https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17121149#comment-17121149
]
Boyang Chen commented on KAFKA-9891:
[~mateuszjadczyk] If we commit keyOne, then it *
[
https://issues.apache.org/jira/browse/KAFKA-10010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10010.
-
Resolution: Fixed
> Should make state store registration idempotent
> --
[
https://issues.apache.org/jira/browse/KAFKA-10011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-10011.
-
Resolution: Fixed
> lockedTaskDirectories should be cleared when task gets closed dirty in
> Ha
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10181:
Summary: Create Envelope RPC and redirection template for configuration
change RPCs (was: Create
[
https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10181:
Fix Version/s: (was: 2.7.0)
2.8.0
> Create Envelope RPC and redirection tem
Boyang Chen created KAFKA-10594:
---
Summary: Enhance Raft exception handling
Key: KAFKA-10594
URL: https://issues.apache.org/jira/browse/KAFKA-10594
Project: Kafka
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10343:
Description: We need to add ApiVersion constraints test based on IBP to
remind future developer bu
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-10343:
---
Assignee: Boyang Chen
> Remove 2.7 IBP for redirection enablement
> ---
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10343:
Summary: Add IBP based ApiVersion constraint tests (was: Remove 2.7 IBP
for redirection enablemen
Boyang Chen created KAFKA-10607:
---
Summary: Ensure the error counts contains the NONE
Key: KAFKA-10607
URL: https://issues.apache.org/jira/browse/KAFKA-10607
Project: Kafka
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-.
Resolution: Won't Fix
> Internal topic creation failure should be non-fatal and trigger explicit
>
Boyang Chen created KAFKA-10657:
---
Summary: Incorporate Envelope into auto-generated JSON schema
Key: KAFKA-10657
URL: https://issues.apache.org/jira/browse/KAFKA-10657
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-10657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10657:
Description:
We need to add support to output JSON format for embed request inside Envelope
to do
Boyang Chen created KAFKA-10663:
---
Summary: Flakey test
ConsumerBounceTest#testSeekAndCommitWithBrokerFailures
Key: KAFKA-10663
URL: https://issues.apache.org/jira/browse/KAFKA-10663
Project: Kafka
Boyang Chen created KAFKA-10667:
---
Summary: Add timeout for forwarding requests
Key: KAFKA-10667
URL: https://issues.apache.org/jira/browse/KAFKA-10667
Project: Kafka
Issue Type: Sub-task
Boyang Chen created KAFKA-10668:
---
Summary: Avoid deserialization on second hop for request forwarding
Key: KAFKA-10668
URL: https://issues.apache.org/jira/browse/KAFKA-10668
Project: Kafka
Issu
[
https://issues.apache.org/jira/browse/KAFKA-10668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10668:
Description:
Right now on forwarding broker we would deserialize the response and serialize
it ag
[
https://issues.apache.org/jira/browse/KAFKA-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10348:
Summary: Consider consolidation of broker to controller communication
(was: Redirect UpdateFeatur
[
https://issues.apache.org/jira/browse/KAFKA-10348?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10348:
Description: Right now, we made forwarding and AlterISR into separate
channels to make non-blockin
[
https://issues.apache.org/jira/browse/KAFKA-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10344:
Description: Original comment:
https://github.com/apache/kafka/pull/9103#discussion_r515427912 (w
[
https://issues.apache.org/jira/browse/KAFKA-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-10344:
Summary: Add active controller check to the controller level in KIP-500
(was: Redirect Create/Ren
Boyang Chen created KAFKA-10674:
---
Summary: Brokers should know the active controller ApiVersion
after enabling KIP-590 forwarding
Key: KAFKA-10674
URL: https://issues.apache.org/jira/browse/KAFKA-10674
[
https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225029#comment-17225029
]
Boyang Chen edited comment on KAFKA-10343 at 11/3/20, 12:32 AM:
--
601 - 700 of 958 matches
Mail list logo
