[jira] [Created] (KAFKA-10663) Flakey test ConsumerBounceTest#testSeekAndCommitWithBrokerFailures

2020-10-29 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10663: --- Summary: Flakey test ConsumerBounceTest#testSeekAndCommitWithBrokerFailures Key: KAFKA-10663 URL: https://issues.apache.org/jira/browse/KAFKA-10663 Project: Kafka

[jira] [Created] (KAFKA-10668) Avoid deserialization on second hop for request forwarding

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

[jira] [Updated] (KAFKA-10668) Avoid deserialization on second hop for request forwarding

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

[jira] [Updated] (KAFKA-10348) Consider consolidation of broker to controller communication

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

[jira] [Created] (KAFKA-10667) Add timeout for forwarding requests

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

[jira] [Updated] (KAFKA-10348) Consider consolidation of broker to controller communication

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

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

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

[jira] [Updated] (KAFKA-10344) Add active controller check to the controller level in KIP-500

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

[jira] [Resolved] (KAFKA-9999) Internal topic creation failure should be non-fatal and trigger explicit rebalance

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

[jira] [Resolved] (KAFKA-10181) Create Envelope RPC and redirection template for configuration change RPCs

2020-11-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-10181. - Resolution: Fixed > Create Envelope RPC and redirection template for configuration change RPCs

[jira] [Created] (KAFKA-10687) Produce request should be bumped for new error code PRODUCE_FENCED

2020-11-05 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-10687: --- Summary: Produce request should be bumped for new error code PRODUCE_FENCED Key: KAFKA-10687 URL: https://issues.apache.org/jira/browse/KAFKA-10687 Project: Kafka

[jira] [Updated] (KAFKA-10687) Produce request should be bumped for new error code PRODUCE_FENCED

2020-11-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10687: Issue Type: Bug (was: Improvement) > Produce request should be bumped for new error code

[jira] [Assigned] (KAFKA-10667) Add timeout for forwarding requests

2020-11-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10667?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-10667: --- Assignee: Boyang Chen > Add timeout for forwarding requests >

[jira] [Updated] (KAFKA-10674) Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding

2020-11-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10674: Parent: KAFKA-9705 Issue Type: Sub-task (was: Improvement) > Brokers should know the

[jira] [Updated] (KAFKA-10674) Brokers should know the active controller ApiVersion after enabling KIP-590 forwarding

2020-11-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10674: Description: Admin clients send ApiVersions to the broker upon the first connection establishes.

[jira] [Commented] (KAFKA-12161) Raft observers should not require an id to fetch

2021-01-07 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17261072#comment-17261072 ] Boyang Chen commented on KAFKA-12161: - I was wondering whether we could just get a random UUID for

[jira] [Created] (KAFKA-12215) Broker could cache its overlapping ApiVersions with active controller

2021-01-15 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-12215: --- Summary: Broker could cache its overlapping ApiVersions with active controller Key: KAFKA-12215 URL: https://issues.apache.org/jira/browse/KAFKA-12215 Project: Kafka

[jira] [Updated] (KAFKA-10348) Consider consolidation of broker to controller communication

2021-02-03 Thread Boyang Chen (Jira)
[ 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

[jira] [Commented] (KAFKA-12169) Consumer can not know paritions chage when client leader restart with static membership protocol

2021-01-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273328#comment-17273328 ] Boyang Chen commented on KAFKA-12169: - In general, the leader should be able to detect metadata

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

2021-01-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-9689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17273379#comment-17273379 ] Boyang Chen commented on KAFKA-9689: I agree with A) since it is internal struct. > Automatic broker

[jira] [Created] (KAFKA-12260) PartitionsFor should not return null value

2021-01-30 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-12260: --- Summary: PartitionsFor should not return null value Key: KAFKA-12260 URL: https://issues.apache.org/jira/browse/KAFKA-12260 Project: Kafka Issue Type:

[jira] [Assigned] (KAFKA-12260) PartitionsFor should not return null value

2021-01-30 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-12260: --- Assignee: Boyang Chen > PartitionsFor should not return null value >

[jira] [Commented] (KAFKA-10733) Enforce exception thrown for KafkaProducer txn APIs

2021-06-11 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17361932#comment-17361932 ] Boyang Chen commented on KAFKA-10733: - Hey [~kkonstantine] I don't think anyone has cycles to push

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

2021-05-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17344088#comment-17344088 ] Boyang Chen commented on KAFKA-10594: - That's correct, thanks! [~jagsancio] > Enhance Raft

[jira] [Updated] (KAFKA-10345) Add auto reloading for trust/key store paths

2021-02-08 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10345?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-10345: Fix Version/s: (was: 2.8.0) 3.0.0 > Add auto reloading for trust/key store

[jira] [Updated] (KAFKA-12294) Consider using the forwarding mechanism for metadata auto topic creation

2021-02-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-12294: Component/s: core > Consider using the forwarding mechanism for metadata auto topic creation >

[jira] [Updated] (KAFKA-12294) Consider using the forwarding mechanism for metadata auto topic creation

2021-02-04 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-12294: Parent: (was: KAFKA-9705) Issue Type: Improvement (was: Sub-task) > Consider using

[jira] [Created] (KAFKA-12294) Consider using the forwarding mechanism for metadata auto topic creation

2021-02-04 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-12294: --- Summary: Consider using the forwarding mechanism for metadata auto topic creation Key: KAFKA-12294 URL: https://issues.apache.org/jira/browse/KAFKA-12294 Project:

[jira] [Created] (KAFKA-12499) Adjust transaction timeout according to commit interval on Streams EOS

2021-03-18 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-12499: --- Summary: Adjust transaction timeout according to commit interval on Streams EOS Key: KAFKA-12499 URL: https://issues.apache.org/jira/browse/KAFKA-12499 Project: Kafka

[jira] [Commented] (KAFKA-12490) Forwarded requests should use timeout from request when possible

2021-03-21 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305880#comment-17305880 ] Boyang Chen commented on KAFKA-12490: - >From what I understand, the Create/DeleteRequest timeout is

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

2021-03-22 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: (was: 2.8.0) 3.0.0 > Zookeeper mutation protocols should be

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

2021-03-22 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: (was: 2.8.0) 3.0.0 > Implement new transaction timed out error

[jira] [Updated] (KAFKA-12381) Incompatible change in verifiable_producer.log in 2.8

2021-03-01 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-12381: Component/s: core > Incompatible change in verifiable_producer.log in 2.8 >

[jira] [Updated] (KAFKA-12381) Incompatible change in verifiable_producer.log in 2.8

2021-03-01 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-12381: Labels: kip-500 (was: ) > Incompatible change in verifiable_producer.log in 2.8 >

[jira] [Commented] (KAFKA-12381) Incompatible change in verifiable_producer.log in 2.8

2021-03-01 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293161#comment-17293161 ] Boyang Chen commented on KAFKA-12381: - [~cmccabe] Could you provide more specific details here, such

[jira] [Commented] (KAFKA-12381) Incompatible change in verifiable_producer.log in 2.8

2021-03-01 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17293286#comment-17293286 ] Boyang Chen commented on KAFKA-12381: - I checked 2.7 code, and we only return

[jira] [Resolved] (KAFKA-12381) Incompatible change in verifiable_producer.log in 2.8

2021-03-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-12381. - Resolution: Fixed > Incompatible change in verifiable_producer.log in 2.8 >

[jira] [Updated] (KAFKA-12381) Incompatible change in verifiable_producer.log in 2.8

2021-03-05 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-12381: Fix Version/s: 2.8.0 > Incompatible change in verifiable_producer.log in 2.8 >

[jira] [Resolved] (KAFKA-7728) Add JoinReason to the join group request for better rebalance handling

2021-04-13 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7728. Resolution: Won't Fix This is no longer a critical fix to the static membership, as leader rejoin

[jira] [Created] (KAFKA-12304) Improve topic validation in auto topic creation

2021-02-05 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-12304: --- Summary: Improve topic validation in auto topic creation Key: KAFKA-12304 URL: https://issues.apache.org/jira/browse/KAFKA-12304 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-12307) Wrap non-fatal exception as CommitFailedException when thrown from commitTxn

2021-02-06 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-12307: --- Summary: Wrap non-fatal exception as CommitFailedException when thrown from commitTxn Key: KAFKA-12307 URL: https://issues.apache.org/jira/browse/KAFKA-12307 Project:

[jira] [Commented] (KAFKA-12169) Consumer can not know paritions change when client leader restart with static membership protocol

2021-02-19 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17287357#comment-17287357 ] Boyang Chen commented on KAFKA-12169: - [~guozhang] One question regarding T1, when we receive the

[jira] [Commented] (KAFKA-13326) Add multi-cluster support to Kafka Streams

2021-09-27 Thread Boyang Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-13326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17421107#comment-17421107 ] Boyang Chen commented on KAFKA-13326: - [~wangguangyuan] Thanks for your interest. There are some

<    5   6   7   8   9   10