[jira] [Created] (KAFKA-10594) Enhance Raft exception handling

2020-10-09 Thread Boyang Chen (Jira)
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

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

2020-10-13 Thread Boyang Chen (Jira)
[ 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

[jira] [Updated] (KAFKA-10343) Remove 2.7 IBP for redirection enablement

2020-10-13 Thread Boyang Chen (Jira)
[ 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

[jira] [Assigned] (KAFKA-10343) Remove 2.7 IBP for redirection enablement

2020-10-13 Thread Boyang Chen (Jira)
[ 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 >

[jira] [Updated] (KAFKA-10343) Remove 2.7 IBP for redirection enablement

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10343: Description: The shipment of redirection could not be complete in 2.7. With that being said, we

[jira] [Updated] (KAFKA-10343) Remove 2.7 IBP for redirection enablement

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10343: Fix Version/s: 2.7.0 > Remove 2.7 IBP for redirection enablement >

[jira] [Created] (KAFKA-10508) Consider moving ForwardRequestHandler to a separate class

2020-09-21 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10508: --- Summary: Consider moving ForwardRequestHandler to a separate class Key: KAFKA-10508 URL: https://issues.apache.org/jira/browse/KAFKA-10508 Project: Kafka

[jira] [Updated] (KAFKA-10343) Remove 2.7 IBP for redirection enablement

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10343: Summary: Remove 2.7 IBP for redirection enablement (was: Redirect AlterClientQuotas to the

[jira] [Assigned] (KAFKA-10350) Add redirect request monitoring metrics

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10350: --- Assignee: Boyang Chen > Add redirect request monitoring metrics >

[jira] [Updated] (KAFKA-10181) Create redirection template for configuration change RPCs

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10181: Description: In the bridge release broker,

[jira] [Updated] (KAFKA-10181) Create redirection template for configuration change RPCs

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10181: Summary: Create redirection template for configuration change RPCs (was: Redirect

[jira] [Commented] (KAFKA-10475) Using same key reports different count of records for groupBy() and groupByKey() in Kafka Streaming Application

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199689#comment-17199689 ] Boyang Chen commented on KAFKA-10475: - [~saad-rasool] [~guozhang]I don't think we have enough

[jira] [Commented] (KAFKA-10504) It will not work to skip to InitProducerId as lastError is always null

2020-09-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17199715#comment-17199715 ] Boyang Chen commented on KAFKA-10504: - Is this optimization necessary? > It will not work to skip

[jira] [Commented] (KAFKA-10513) Newly added topic or partitions are not assigned to running consumer groups using static membership

2020-09-28 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17203342#comment-17203342 ] Boyang Chen commented on KAFKA-10513: - My understanding is that the consumer was supposed to check

[jira] [Assigned] (KAFKA-9878) Block AddPartitionsToTxn call until the txn markers are committed

2020-05-27 Thread Boyang Chen (Jira)
[ 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 >

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread Boyang Chen (Jira)
[ 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 >

[jira] [Updated] (KAFKA-10038) ConsumerPerformance.scala supports the setting of client.id

2020-05-25 Thread Boyang Chen (Jira)
[ 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

[jira] [Updated] (KAFKA-9878) Block AddPartitionsToTxn call until the txn markers are committed

2020-05-25 Thread Boyang Chen (Jira)
[ 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

[jira] [Updated] (KAFKA-9146) Add option to force delete members in stream reset tool

2020-05-25 Thread Boyang Chen (Jira)
[ 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 >

[jira] [Created] (KAFKA-10042) Make INVALID_PRODUCER_EPOCH abortable from Produce response

2020-05-25 Thread Boyang Chen (Jira)
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

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

2020-05-25 Thread Boyang Chen (Jira)
[ 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 >

[jira] [Created] (KAFKA-10064) Add documentation for KIP-571

2020-05-28 Thread Boyang Chen (Jira)
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

[jira] [Updated] (KAFKA-10055) Add shared internal utility class for Streams module

2020-05-29 Thread Boyang Chen (Jira)
[ 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

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

2020-05-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119899#comment-17119899 ] Boyang Chen commented on KAFKA-9891: [~mateuszjadczyk] I ran your example again, and could see that

[jira] [Resolved] (KAFKA-10010) Should make state store registration idempotent

2020-06-01 Thread Boyang Chen (Jira)
[ 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 >

[jira] [Resolved] (KAFKA-10011) lockedTaskDirectories should be cleared when task gets closed dirty in HandleLostAll

2020-06-01 Thread Boyang Chen (Jira)
[ 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 >

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

2020-06-01 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9891?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17121149#comment-17121149 ] Boyang Chen commented on KAFKA-9891: [~mateuszjadczyk] If we commit keyOne, then it *should* be

[jira] [Updated] (KAFKA-9910) Implement new transaction timed out error

2020-09-19 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9910: --- Component/s: core clients > Implement new transaction timed out error >

[jira] [Updated] (KAFKA-9910) Implement new transaction timed out error

2020-09-19 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9910: --- Fix Version/s: 2.7.0 > Implement new transaction timed out error >

[jira] [Resolved] (KAFKA-10270) Add a broker to controller channel manager to redirect AlterConfig

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10270. - Resolution: Fixed > Add a broker to controller channel manager to redirect AlterConfig >

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

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10181: Summary: Redirect AlterConfig/IncrementalAlterConfig to the controller (was:

[jira] [Updated] (KAFKA-10270) Add a broker to controller channel manager to redirect AlterConfig

2020-07-29 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10270: Fix Version/s: 2.7.0 > Add a broker to controller channel manager to redirect AlterConfig >

[jira] [Created] (KAFKA-10350) Add redirect request monitoring metrics

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10350: --- Summary: Add redirect request monitoring metrics Key: KAFKA-10350 URL: https://issues.apache.org/jira/browse/KAFKA-10350 Project: Kafka Issue Type: Sub-task

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

2020-08-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10181: Description: In the bridge release broker, AlterConfig/IncrementalAlterConfig should be

[jira] [Updated] (KAFKA-10343) Redirect AlterClientQuotas to the controller

2020-08-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10343: Description: In the bridge release broker, AlterClientQuotas should be redirected to the active

[jira] [Updated] (KAFKA-10342) Redirect Create/DeleteAcls to the controller

2020-08-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Description: In the bridge release broker,Create/DeleteAcls should be redirected to the active

[jira] [Updated] (KAFKA-9705) Zookeeper mutation protocols should be redirected to Controller only

2020-08-03 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: --- Fix Version/s: 2.7.0 > Zookeeper mutation protocols should be redirected to Controller only >

[jira] [Created] (KAFKA-10349) Deprecate client side controller access

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10349: --- Summary: Deprecate client side controller access Key: KAFKA-10349 URL: https://issues.apache.org/jira/browse/KAFKA-10349 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10348) Redirect UpdateFeatures to the controller

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10348: --- Summary: Redirect UpdateFeatures to the controller Key: KAFKA-10348 URL: https://issues.apache.org/jira/browse/KAFKA-10348 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-10347) Redirect Create/DeleteTopics to the controller

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10347: --- Summary: Redirect Create/DeleteTopics to the controller Key: KAFKA-10347 URL: https://issues.apache.org/jira/browse/KAFKA-10347 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10345) Redirect AlterPartitionReassignment to the controller

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10345: --- Summary: Redirect AlterPartitionReassignment to the controller Key: KAFKA-10345 URL: https://issues.apache.org/jira/browse/KAFKA-10345 Project: Kafka Issue

[jira] [Created] (KAFKA-10343) Redirect AlterClientQuotas to the controller

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10343: --- Summary: Redirect AlterClientQuotas to the controller Key: KAFKA-10343 URL: https://issues.apache.org/jira/browse/KAFKA-10343 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-10344) Redirect Create/Renew/ExpireDelegationToken to the controller

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10344: --- Summary: Redirect Create/Renew/ExpireDelegationToken to the controller Key: KAFKA-10344 URL: https://issues.apache.org/jira/browse/KAFKA-10344 Project: Kafka

[jira] [Updated] (KAFKA-10342) Redirect Create/DeleteAcls to the controller

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

[jira] [Updated] (KAFKA-10342) Redirect Create/DeleteAcls to the controller

2020-08-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10342: Description: In the new Admin client, the CreateAcls/DeleteAcls request should be redirected to

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

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

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

2020-08-03 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9751: --- Description: For use cases to create internal topics through FindCoordinator or Metadata request,

[jira] [Created] (KAFKA-10342) Redirect CreateAcls/DeleteAcls to the controller

2020-08-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10342: --- Summary: Redirect CreateAcls/DeleteAcls to the controller Key: KAFKA-10342 URL: https://issues.apache.org/jira/browse/KAFKA-10342 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-10349) Deprecate client side controller access

2020-08-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10349: Description: As stated in KIP-590, we would disallow new admin client to discover the controller

[jira] [Resolved] (KAFKA-9911) Implement new producer fenced error

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9911. Resolution: Fixed > Implement new producer fenced error > --- > >

[jira] [Updated] (KAFKA-9911) Implement new producer fenced error

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9911: --- Fix Version/s: 2.7.0 > Implement new producer fenced error > --- > >

[jira] [Assigned] (KAFKA-9911) Implement new producer fenced error

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-9911: -- Assignee: Boyang Chen > Implement new producer fenced error >

[jira] [Updated] (KAFKA-9911) Implement new producer fenced error

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9911?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9911: --- Component/s: producer > Implement new producer fenced error > --- >

[jira] [Commented] (KAFKA-10354) Kafka Bug

2020-08-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171040#comment-17171040 ] Boyang Chen commented on KAFKA-10354: - What's this ticket about? > Kafka Bug > - > >

[jira] [Commented] (KAFKA-4587) Rethink Unification of Caching with Dedupping

2020-08-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17170971#comment-17170971 ] Boyang Chen commented on KAFKA-4587: What's the status of this ticket? Do we still want to work on

[jira] [Assigned] (KAFKA-10042) Make INVALID_PRODUCER_EPOCH abortable from Produce response

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10042: --- Assignee: Boyang Chen > Make INVALID_PRODUCER_EPOCH abortable from Produce response >

[jira] [Resolved] (KAFKA-10042) Make INVALID_PRODUCER_EPOCH abortable from Produce response

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10042. - Resolution: Fixed > Make INVALID_PRODUCER_EPOCH abortable from Produce response >

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

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176639#comment-17176639 ] Boyang Chen commented on KAFKA-10284: - I would say for all. > Group membership update due to static

[jira] [Updated] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-9803: --- Fix Version/s: 2.7.0 > Allow producers to recover gracefully from transaction timeouts >

[jira] [Updated] (KAFKA-10042) Make INVALID_PRODUCER_EPOCH abortable from Produce response

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10042: Fix Version/s: 2.7.0 > Make INVALID_PRODUCER_EPOCH abortable from Produce response >

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

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10284: --- Assignee: Boyang Chen > Group membership update due to static member rejoin should be

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

2020-08-12 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17176639#comment-17176639 ] Boyang Chen edited comment on KAFKA-10284 at 8/12/20, 10:48 PM: I would

[jira] [Created] (KAFKA-10400) Add a customized Kafka Streams logo

2020-08-13 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10400: --- Summary: Add a customized Kafka Streams logo Key: KAFKA-10400 URL: https://issues.apache.org/jira/browse/KAFKA-10400 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-9007) Flaky Test kafka.api.SaslPlaintextConsumerTest.testCoordinatorFailover

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

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

2020-08-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10284: Labels: help-wanted (was: ) > Group membership update due to static member rejoin should be

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

2020-08-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10284: --- Assignee: (was: Boyang Chen) > Group membership update due to static member rejoin

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

2020-08-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17175669#comment-17175669 ] Boyang Chen commented on KAFKA-10284: - Resign from this ticket for now, others feel free to pick up.

[jira] [Commented] (KAFKA-8033) Flaky Test PlaintextConsumerTest#testFetchInvalidOffset

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

[jira] [Commented] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

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

[jira] [Updated] (KAFKA-9009) Flaky Test kafka.integration.MetricsDuringTopicCreationDeletionTest.testMetricsDuringTopicCreateDelete

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

[jira] [Commented] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

2020-07-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17150519#comment-17150519 ] Boyang Chen commented on KAFKA-6520: [~VinceMu] Gave you contributor permission and assign the ticket

[jira] [Commented] (KAFKA-9831) Failing test: EosIntegrationTest.shouldNotViolateEosIfOneTaskFailsWithState[exactly_once_beta]

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

[jira] [Assigned] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

2020-07-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-6520: -- Assignee: Vince Mu (was: Milind Jain) > When a Kafka Stream can't communicate with the

[jira] [Assigned] (KAFKA-6520) When a Kafka Stream can't communicate with the server, it's Status stays RUNNING

2020-07-02 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-6520: -- Assignee: Milind Jain > When a Kafka Stream can't communicate with the server, it's Status

[jira] [Commented] (KAFKA-10219) KStream API support for multiple cluster broker

2020-06-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17148818#comment-17148818 ] Boyang Chen commented on KAFKA-10219: - Thanks for the proposal, the use case you proposed is

[jira] [Commented] (KAFKA-10242) Adding metrics to track the total count of idempotent producers that Broker need to track

2020-07-07 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17153229#comment-17153229 ] Boyang Chen commented on KAFKA-10242: - Is this really critical? I think we could downgrade to major. 

[jira] [Updated] (KAFKA-10270) Add a broker to controller channel manager to redirect AlterConfig

2020-07-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10270: Description: Per KIP-590 requirement, we need to have a dedicate communication channel from

[jira] [Created] (KAFKA-10270) Add a broker to controller channel manager to redirect AlterConfig

2020-07-13 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10270: --- Summary: Add a broker to controller channel manager to redirect AlterConfig Key: KAFKA-10270 URL: https://issues.apache.org/jira/browse/KAFKA-10270 Project: Kafka

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

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

[jira] [Assigned] (KAFKA-10239) The groupInstanceId field in DescribeGroup response should be ignorable

2020-07-06 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10239: --- Assignee: Boyang Chen > The groupInstanceId field in DescribeGroup response should be

[jira] [Created] (KAFKA-10237) Properly handle in-memory stores OOM

2020-07-06 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10237: --- Summary: Properly handle in-memory stores OOM Key: KAFKA-10237 URL: https://issues.apache.org/jira/browse/KAFKA-10237 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-10168) Rename public StreamsConfig variable

2020-06-15 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17136292#comment-17136292 ] Boyang Chen commented on KAFKA-10168: - [~sbellapu] There is already a WIP PR for this change  >

[jira] [Created] (KAFKA-10192) Flaky test BlockingConnectorTest#testBlockInConnectorStop

2020-06-22 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10192: --- Summary: Flaky test BlockingConnectorTest#testBlockInConnectorStop Key: KAFKA-10192 URL: https://issues.apache.org/jira/browse/KAFKA-10192 Project: Kafka

[jira] [Commented] (KAFKA-10055) Add shared internal utility class for Streams module

2020-06-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142429#comment-17142429 ] Boyang Chen commented on KAFKA-10055: - Need to move to the shared utility class as well > Add

[jira] [Comment Edited] (KAFKA-10055) Add shared internal utility class for Streams module

2020-06-22 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17142429#comment-17142429 ] Boyang Chen edited comment on KAFKA-10055 at 6/22/20, 9:32 PM: --- Need to

[jira] [Commented] (KAFKA-10192) Flaky test BlockingConnectorTest#testBlockInConnectorStop

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

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

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

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

2020-06-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Fix Version/s: 2.7.0 > Deprecate unused options in ConsumerPerformance >

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

2020-06-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10135: Affects Version/s: 2.6.0 2.5.0 > Extract Task#executeAndMaybeSwallow to be

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

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

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

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

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

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

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

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

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

2020-06-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10126: Priority: Minor (was: Major) > Deprecate unused options in ConsumerPerformance >

[jira] [Commented] (KAFKA-10173) BufferUnderflowException during Kafka Streams Upgrade

2020-06-24 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17144573#comment-17144573 ] Boyang Chen commented on KAFKA-10173: - cc [~rhauch] > BufferUnderflowException during Kafka Streams

[jira] [Updated] (KAFKA-10189) Reset metric EventQueueTimeMs

2020-06-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10189: Labels: core (was: pull-request-available) > Reset metric EventQueueTimeMs >

[jira] [Updated] (KAFKA-10189) Reset metric EventQueueTimeMs

2020-06-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10189: Component/s: core > Reset metric EventQueueTimeMs > -- > >

[jira] [Updated] (KAFKA-10189) Reset metric EventQueueTimeMs

2020-06-26 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10189: Labels: (was: core) > Reset metric EventQueueTimeMs > -- > >

[jira] [Commented] (KAFKA-10196) Add missing '--version' option to Kafka command producer-performance

2020-06-28 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147509#comment-17147509 ] Boyang Chen commented on KAFKA-10196: - Why do we need to display version from the command line? The

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

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

<    3   4   5   6   7   8   9   10   >