[jira] [Resolved] (KAFKA-7830) Convert Kafka RPCs to use automatically generated code

2019-05-08 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7830. Resolution: Fixed > Convert Kafka RPCs to use automatically generated code > --

[jira] [Created] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

2019-05-08 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8342: -- Summary: Admin tool to setup Kafka Stream topology (internal) topics Key: KAFKA-8342 URL: https://issues.apache.org/jira/browse/KAFKA-8342 Project: Kafka Issue

[jira] [Updated] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

2019-05-08 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8342: --- Labels: newbie (was: ) > Admin tool to setup Kafka Stream topology (internal) topics > -

[jira] [Updated] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

2019-05-08 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8342: --- Issue Type: New Feature (was: Bug) > Admin tool to setup Kafka Stream topology (internal) topics > -

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

2019-05-08 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836068#comment-16836068 ] Boyang Chen commented on KAFKA-8311: [~clearpal7] Thanks for interest! You need to se

[jira] [Resolved] (KAFKA-8284) Enable static membership on KStream

2019-05-08 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8284. Resolution: Fixed > Enable static membership on KStream > --- > >

[jira] [Assigned] (KAFKA-8311) Better consumer timeout exception handling

2019-05-08 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8311: -- Assignee: (was: Boyang Chen) > Better consumer timeout exception handling > -

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

2019-05-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836813#comment-16836813 ] Boyang Chen commented on KAFKA-8311: [~mjsax] [~clearpal7] Thank you both! If you won

[jira] [Comment Edited] (KAFKA-8311) Better consumer timeout exception handling

2019-05-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836813#comment-16836813 ] Boyang Chen edited comment on KAFKA-8311 at 5/10/19 1:09 AM: -

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

2019-05-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16836820#comment-16836820 ] Boyang Chen commented on KAFKA-8230: [~ijuma] woo, miss this point! > Add static mem

[jira] [Resolved] (KAFKA-7858) Replace JoinGroup request/response with automated protocol

2019-05-10 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7858. Resolution: Fixed > Replace JoinGroup request/response with automated protocol > --

[jira] [Created] (KAFKA-8354) Replace SyncGroup request/response with automated protocol

2019-05-10 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8354: -- Summary: Replace SyncGroup request/response with automated protocol Key: KAFKA-8354 URL: https://issues.apache.org/jira/browse/KAFKA-8354 Project: Kafka Issue Ty

[jira] [Created] (KAFKA-8355) Add static membership to Range assignor

2019-05-10 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8355: -- Summary: Add static membership to Range assignor Key: KAFKA-8355 URL: https://issues.apache.org/jira/browse/KAFKA-8355 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8356) Add static membership to Round Robin assignor

2019-05-10 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8356: -- Summary: Add static membership to Round Robin assignor Key: KAFKA-8356 URL: https://issues.apache.org/jira/browse/KAFKA-8356 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-8224) Add static member id into Subscription Info for better rebalance behavior

2019-05-10 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8224: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-7018) > Add static member id

[jira] [Assigned] (KAFKA-8354) Replace SyncGroup request/response with automated protocol

2019-05-12 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8354: -- Assignee: Boyang Chen > Replace SyncGroup request/response with automated protocol > -

[jira] [Commented] (KAFKA-7670) Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer

2019-05-15 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7670?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16840676#comment-16840676 ] Boyang Chen commented on KAFKA-7670: Hey Stanis, seems that test gets flakey again: 

[jira] [Created] (KAFKA-8373) Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols

2019-05-15 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8373: -- Summary: Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols Key: KAFKA-8373 URL: https://issues.apache.org/jira/browse/KAFKA-8373 Project: Kafka

[jira] [Resolved] (KAFKA-8354) Replace SyncGroup request/response with automated protocol

2019-05-17 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8354?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8354. Resolution: Fixed > Replace SyncGroup request/response with automated protocol > --

[jira] [Created] (KAFKA-8386) Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available

2019-05-17 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8386: -- Summary: Use COORDINATOR_NOT_AVAILABLE to replace UNKNOWN_MEMBER_ID when the group is not available Key: KAFKA-8386 URL: https://issues.apache.org/jira/browse/KAFKA-8386

[jira] [Created] (KAFKA-8387) Add `Fenced` state to AbstractCoordinator

2019-05-17 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8387: -- Summary: Add `Fenced` state to AbstractCoordinator Key: KAFKA-8387 URL: https://issues.apache.org/jira/browse/KAFKA-8387 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8225) Handle conflicting static member id

2019-05-18 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8225. Resolution: Fixed > Handle conflicting static member id > --- > >

[jira] [Resolved] (KAFKA-8373) Add group.instance.id field into Sync/Heartbeat/OffsetCommit protocols

2019-05-18 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8373?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8373. Resolution: Fixed Addressed in [https://github.com/apache/kafka/pull/6650/] > Add group.instance.i

[jira] [Updated] (KAFKA-8220) Avoid kicking out members through rebalance timeout

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8220: --- Fix Version/s: 2.3.0 > Avoid kicking out members through rebalance timeout >

[jira] [Updated] (KAFKA-7862) Modify JoinGroup logic to incorporate group.instance.id change

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7862: --- Fix Version/s: 2.3.0 > Modify JoinGroup logic to incorporate group.instance.id change > -

[jira] [Updated] (KAFKA-8225) Handle conflicting static member id

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8225: --- Fix Version/s: 2.3.0 > Handle conflicting static member id > --- > >

[jira] [Updated] (KAFKA-8284) Enable static membership on KStream

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8284: --- Fix Version/s: 2.3.0 > Enable static membership on KStream > --- > >

[jira] [Commented] (KAFKA-8207) StickyPartitionAssignor for KStream

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844168#comment-16844168 ] Boyang Chen commented on KAFKA-8207: Hey [~neeraj.bhatt] thank you for your interest!

[jira] [Comment Edited] (KAFKA-8207) StickyPartitionAssignor for KStream

2019-05-20 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8207?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16844168#comment-16844168 ] Boyang Chen edited comment on KAFKA-8207 at 5/20/19 6:01 PM: -

[jira] [Created] (KAFKA-8397) Add pre-registration feature for static membership

2019-05-20 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8397: -- Summary: Add pre-registration feature for static membership Key: KAFKA-8397 URL: https://issues.apache.org/jira/browse/KAFKA-8397 Project: Kafka Issue Type: Impr

[jira] [Created] (KAFKA-8399) Add back `internal.leave.group.on.close` config for KStreams

2019-05-20 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8399: -- Summary: Add back `internal.leave.group.on.close` config for KStreams Key: KAFKA-8399 URL: https://issues.apache.org/jira/browse/KAFKA-8399 Project: Kafka Issue

[jira] [Created] (KAFKA-8424) Replace ListGroups request/response with automated protocol

2019-05-23 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8424: -- Summary: Replace ListGroups request/response with automated protocol Key: KAFKA-8424 URL: https://issues.apache.org/jira/browse/KAFKA-8424 Project: Kafka Issue

[jira] [Commented] (KAFKA-8311) Better consumer timeout exception handling

2019-05-23 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847170#comment-16847170 ] Boyang Chen commented on KAFKA-8311: [~clearpal7] No worry, let me take a look of you

[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

2019-05-23 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847174#comment-16847174 ] Boyang Chen commented on KAFKA-8342: [~clearpal7] Let me know if this sounds interest

[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

2019-05-23 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16847286#comment-16847286 ] Boyang Chen commented on KAFKA-8342: [~clearpal7] Yea, feel free to take it. I will p

[jira] [Assigned] (KAFKA-8356) Add static membership to Round Robin assignor

2019-05-24 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8356: -- Assignee: Boyang Chen > Add static membership to Round Robin assignor > --

[jira] [Created] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

2019-05-24 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8430: -- Summary: Unit test to make sure `group.id` and `group.instance.id` won't affect each other Key: KAFKA-8430 URL: https://issues.apache.org/jira/browse/KAFKA-8430 Project:

[jira] [Created] (KAFKA-8432) Add static membership to Sticky assignor

2019-05-26 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8432: -- Summary: Add static membership to Sticky assignor Key: KAFKA-8432 URL: https://issues.apache.org/jira/browse/KAFKA-8432 Project: Kafka Issue Type: Sub-task

[jira] [Assigned] (KAFKA-8432) Add static membership to Sticky assignor

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8432: -- Assignee: Boyang Chen > Add static membership to Sticky assignor > ---

[jira] [Assigned] (KAFKA-8355) Add static membership to Range assignor

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8355?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8355: -- Assignee: Boyang Chen > Add static membership to Range assignor >

[jira] [Resolved] (KAFKA-8246) refactor topic/group instance id validation condition

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8246. Resolution: Not A Problem Since it's only one time validation, we don't need to refactor. > refact

[jira] [Commented] (KAFKA-7788) Support null defaults in KAFKA-7609 RPC specifications

2019-05-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848646#comment-16848646 ] Boyang Chen commented on KAFKA-7788: [~hachikuji] Is this being solved by  [https://g

[jira] [Created] (KAFKA-8435) Replace DeleteGroups request/response with automated protocol

2019-05-26 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8435: -- Summary: Replace DeleteGroups request/response with automated protocol Key: KAFKA-8435 URL: https://issues.apache.org/jira/browse/KAFKA-8435 Project: Kafka Issu

[jira] [Created] (KAFKA-8436) Replace AddOffsetsToTxn request/response with automated protocol

2019-05-26 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8436: -- Summary: Replace AddOffsetsToTxn request/response with automated protocol Key: KAFKA-8436 URL: https://issues.apache.org/jira/browse/KAFKA-8436 Project: Kafka I

[jira] [Resolved] (KAFKA-8219) Add web documentation for static membership

2019-05-27 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8219?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8219. Resolution: Fixed > Add web documentation for static membership > -

[jira] [Commented] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

2019-05-27 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849322#comment-16849322 ] Boyang Chen commented on KAFKA-8438: Thanks for the proposal [~Yohan123]! it definite

[jira] [Commented] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

2019-05-28 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8430?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16849923#comment-16849923 ] Boyang Chen commented on KAFKA-8430: After checking the code in `KafkaConsumer`, I fo

[jira] [Assigned] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

2019-05-28 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8430: -- Assignee: Boyang Chen > Unit test to make sure `group.id` and `group.instance.id` won't affect

[jira] [Created] (KAFKA-8445) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-05-28 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8445: -- Summary: Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride Key: KAFKA-8445 URL: https://issues.apache.org/jira/browse/KAFKA-8445 Proj

[jira] [Updated] (KAFKA-8445) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-05-28 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8445: --- Description: [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/8/console] Trace: *11:30:48

[jira] [Updated] (KAFKA-8445) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-05-28 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8445: --- Description: [https://builds.apache.org/job/kafka-pr-jdk8-scala2.11/8/console] Trace: ```  *11

[jira] [Resolved] (KAFKA-8430) Unit test to make sure `group.id` and `group.instance.id` won't affect each other

2019-05-28 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8430. Resolution: Fixed > Unit test to make sure `group.id` and `group.instance.id` won't affect each >

[jira] [Created] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

2019-05-29 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8446: -- Summary: KStream restoration will crash with NPE when the record value is null Key: KAFKA-8446 URL: https://issues.apache.org/jira/browse/KAFKA-8446 Project: Kafka

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

2019-05-29 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Affects Version/s: 2.3.0 > KStream restoration will crash with NPE when the record value is null > --

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

2019-05-29 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Fix Version/s: (was: 2.3.0) > KStream restoration will crash with NPE when the record value is nu

[jira] [Updated] (KAFKA-8446) KStream restoration will crash with NPE when the record value is null

2019-05-29 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Fix Version/s: 2.3.0 > KStream restoration will crash with NPE when the record value is null > --

[jira] [Commented] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

2019-05-30 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852639#comment-16852639 ] Boyang Chen commented on KAFKA-8438: Hey Richard, thanks for the update. I'm still no

[jira] [Comment Edited] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

2019-05-30 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852639#comment-16852639 ] Boyang Chen edited comment on KAFKA-8438 at 5/31/19 4:20 AM: -

[jira] [Comment Edited] (KAFKA-8438) Add API to allow user to define end behavior of consumer failure

2019-05-30 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852639#comment-16852639 ] Boyang Chen edited comment on KAFKA-8438 at 5/31/19 4:20 AM: -

[jira] [Updated] (KAFKA-8446) Kafka Streams restoration crashes with NPE when the record value is null

2019-05-30 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8446: --- Description: To add more context here: a NPE will be triggered in *RecordConverters#ByteBuffer.alloc

[jira] [Created] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8456: -- Summary: Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi Key: KAFKA-8456 URL: https://issues.apache.org/jira/browse/KAFKA-8

[jira] [Created] (KAFKA-8459) Flakey test BaseQuotaTest#testThrottledRequest

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8459: -- Summary: Flakey test BaseQuotaTest#testThrottledRequest Key: KAFKA-8459 URL: https://issues.apache.org/jira/browse/KAFKA-8459 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8459) Flakey test BaseQuotaTest#testThrottledRequest

2019-05-31 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853452#comment-16853452 ] Boyang Chen commented on KAFKA-8459: [~guozhang] [~rsivaram]What's the normal procedu

[jira] [Created] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8460: -- Summary: Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition Key: KAFKA-8460 URL: https://issues.apache.org/jira/browse/KAFKA-8460 Project: Kafka

[jira] [Updated] (KAFKA-8460) Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition

2019-05-31 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8460: --- Description: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/5168/consoleFull]  *16:17:04*

[jira] [Created] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-05-31 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8461: -- Summary: Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride Key: KAFKA-8461 URL: https://issues.apache.org/jira/browse/KAFKA-8461 Proj

[jira] [Created] (KAFKA-8462) flakey test RestServerTest#testCORSEnabled

2019-06-01 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8462: -- Summary: flakey test RestServerTest#testCORSEnabled Key: KAFKA-8462 URL: https://issues.apache.org/jira/browse/KAFKA-8462 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-06-01 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853729#comment-16853729 ] Boyang Chen commented on KAFKA-8461: It failed for second time at the same place  [h

[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-06-01 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853730#comment-16853730 ] Boyang Chen commented on KAFKA-8461: Another reported on[8445|https://issues.apache.o

[jira] [Resolved] (KAFKA-8445) Flaky Test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-06-01 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8445. Resolution: Duplicate > Flaky Test > UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledB

[jira] [Comment Edited] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-06-01 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16853730#comment-16853730 ] Boyang Chen edited comment on KAFKA-8461 at 6/1/19 2:57 PM: A

[jira] [Updated] (KAFKA-8447) New Metric to Measure Number of Tasks on a Connector

2019-06-04 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8447: --- Component/s: KafkaConnect > New Metric to Measure Number of Tasks on a Connector > --

[jira] [Created] (KAFKA-8489) Remove group immediately when DeleteGroup request could be completed

2019-06-05 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8489: -- Summary: Remove group immediately when DeleteGroup request could be completed Key: KAFKA-8489 URL: https://issues.apache.org/jira/browse/KAFKA-8489 Project: Kafka

[jira] [Created] (KAFKA-8490) Use `Migrated` and `Deleted` state to replace consumer group `Dead` state

2019-06-05 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8490: -- Summary: Use `Migrated` and `Deleted` state to replace consumer group `Dead` state Key: KAFKA-8490 URL: https://issues.apache.org/jira/browse/KAFKA-8490 Project: Kafka

[jira] [Assigned] (KAFKA-8489) Remove group immediately when DeleteGroup request could be completed

2019-06-05 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8489: -- Assignee: Boyang Chen > Remove group immediately when DeleteGroup request could be completed >

[jira] [Commented] (KAFKA-8495) Make Round-robin / RangeAssignor to be "sticky" (part 5)

2019-06-05 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857233#comment-16857233 ] Boyang Chen commented on KAFKA-8495: FYI we do have one ongoing diff to make those co

[jira] [Created] (KAFKA-8500) member.id should always update upon static member rejoin despite of group state

2019-06-06 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8500: -- Summary: member.id should always update upon static member rejoin despite of group state Key: KAFKA-8500 URL: https://issues.apache.org/jira/browse/KAFKA-8500 Project: Ka

[jira] [Commented] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

2019-06-06 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858330#comment-16858330 ] Boyang Chen commented on KAFKA-8461: [https://builds.apache.org/job/kafka-pr-jdk11-sc

[jira] [Created] (KAFKA-8502) Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions

2019-06-06 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8502: -- Summary: Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions Key: KAFKA-8502 URL: https://issues.apache.org/jira/browse/KAFKA-8502 Project: Kaf

[jira] [Commented] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

2019-06-07 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16858766#comment-16858766 ] Boyang Chen commented on KAFKA-8506: Why broker calles `consumer.poll`? > Kafka Cons

[jira] [Created] (KAFKA-8515) Materialize KTable when upstream uses Windowed instead of

2019-06-09 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8515: -- Summary: Materialize KTable when upstream uses Windowed instead of Key: KAFKA-8515 URL: https://issues.apache.org/jira/browse/KAFKA-8515 Project: Kafka Issue T

[jira] [Updated] (KAFKA-8515) Materialize KTable when upstream uses Windowed instead of

2019-06-09 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8515: --- Issue Type: Sub-task (was: Improvement) Parent: KAFKA-6840 > Materialize KTable when upstrea

[jira] [Updated] (KAFKA-8500) member.id should always update upon static member rejoin despite of group state

2019-06-10 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8500: --- Issue Type: Bug (was: Improvement) > member.id should always update upon static member rejoin despit

[jira] [Updated] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

2019-06-10 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8487: --- Affects Version/s: 2.3 > Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit >

[jira] [Updated] (KAFKA-8487) Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit response handler

2019-06-10 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8487: --- Component/s: streams > Consumer should not resetGeneration upon REBALANCE_IN_PROGRESS in commit > re

[jira] [Commented] (KAFKA-8502) Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861154#comment-16861154 ] Boyang Chen commented on KAFKA-8502: [https://builds.apache.org/job/kafka-pr-jdk11-sc

[jira] [Commented] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861155#comment-16861155 ] Boyang Chen commented on KAFKA-8456: Failed again:  [https://builds.apache.org/job/ka

[jira] [Commented] (KAFKA-8391) Flaky Test RebalanceSourceConnectorsIntegrationTest#testDeleteConnector

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861519#comment-16861519 ] Boyang Chen commented on KAFKA-8391: Failed again:  [https://builds.apache.org/job/ka

[jira] [Commented] (KAFKA-8456) Flaky Test StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861525#comment-16861525 ] Boyang Chen commented on KAFKA-8456: [~mjsax] Any tip for debugging this? > Flaky Te

[jira] [Commented] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861639#comment-16861639 ] Boyang Chen commented on KAFKA-8262: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Commented] (KAFKA-8113) Flaky Test ListOffsetsRequestTest#testResponseIncludesLeaderEpoch

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861750#comment-16861750 ] Boyang Chen commented on KAFKA-8113: Failed again  [https://builds.apache.org/job/kaf

[jira] [Commented] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

2019-06-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16861788#comment-16861788 ] Boyang Chen commented on KAFKA-8263: ``` [2019-06-11 04:24:38,981] WARN [RequestSendT

[jira] [Commented] (KAFKA-7947) Flaky Test EpochDrivenReplicationProtocolAcceptanceTest#shouldFollowLeaderEpochBasicWorkflow

2019-06-12 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16862230#comment-16862230 ] Boyang Chen commented on KAFKA-7947: [https://builds.apache.org/job/kafka-pr-jdk8-sca

[jira] [Created] (KAFKA-8529) Flakey test ConsumerBounceTest#testCloseDuringRebalance

2019-06-12 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8529: -- Summary: Flakey test ConsumerBounceTest#testCloseDuringRebalance Key: KAFKA-8529 URL: https://issues.apache.org/jira/browse/KAFKA-8529 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-8223) Deprecate group.initial.rebalance.delay

2019-06-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8223. Resolution: Later > Deprecate group.initial.rebalance.delay > -

[jira] [Created] (KAFKA-8538) Add `group.instance.id` to DescribeGroup for better visibility

2019-06-13 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8538: -- Summary: Add `group.instance.id` to DescribeGroup for better visibility Key: KAFKA-8538 URL: https://issues.apache.org/jira/browse/KAFKA-8538 Project: Kafka Iss

[jira] [Created] (KAFKA-8539) Add `getGroupInstanceId` call to Subscription class

2019-06-13 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8539: -- Summary: Add `getGroupInstanceId` call to Subscription class Key: KAFKA-8539 URL: https://issues.apache.org/jira/browse/KAFKA-8539 Project: Kafka Issue Type: Sub

[jira] [Updated] (KAFKA-8539) Add `group.instance.id` to Subscription class

2019-06-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8539: --- Summary: Add `group.instance.id` to Subscription class (was: Add `getGroupInstanceId` call to Subscr

[jira] [Assigned] (KAFKA-8539) Add `group.instance.id` to Subscription class

2019-06-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8539: -- Assignee: Boyang Chen > Add `group.instance.id` to Subscription class > --

[jira] [Commented] (KAFKA-8108) Flaky Test kafka.api.ClientIdQuotaTest.testThrottledProducerConsumer

2019-06-13 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16863602#comment-16863602 ] Boyang Chen commented on KAFKA-8108: [https://builds.apache.org/job/kafka-pr-jdk11-sc

<    3   4   5   6   7   8   9   10   >