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

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8219: -- Summary: Add web documentation for static membership Key: KAFKA-8219 URL: https://issues.apache.org/jira/browse/KAFKA-8219 Project: Kafka Issue Type: Sub-task

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

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8220: -- Summary: Avoid kicking out members through rebalance timeout Key: KAFKA-8220 URL: https://issues.apache.org/jira/browse/KAFKA-8220 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-8221) Augment LeaveGroupRequest to batch operation

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8221: -- Summary: Augment LeaveGroupRequest to batch operation Key: KAFKA-8221 URL: https://issues.apache.org/jira/browse/KAFKA-8221 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8222) Admin client changes to add ability to batch remove static members

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8222: -- Summary: Admin client changes to add ability to batch remove static members Key: KAFKA-8222 URL: https://issues.apache.org/jira/browse/KAFKA-8222 Project: Kafka

[jira] [Updated] (KAFKA-8222) Admin client changes to add ability to batch remove static members

2019-04-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8222: --- Description: After leave group [changes|https://issues.apache.org/jira/browse/KAFKA-8221] become effe

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

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8223: -- Summary: Deprecate group.initial.rebalance.delay Key: KAFKA-8223 URL: https://issues.apache.org/jira/browse/KAFKA-8223 Project: Kafka Issue Type: Sub-task

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

2019-04-11 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8224: -- Assignee: Boyang Chen > Add static member id into Subscription Info for better rebalance behav

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

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8224: -- Summary: Add static member id into Subscription Info for better rebalance behavior Key: KAFKA-8224 URL: https://issues.apache.org/jira/browse/KAFKA-8224 Project: Kafka

[jira] [Created] (KAFKA-8225) handle conflicting static member id

2019-04-11 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8225: -- Summary: handle conflicting static member id Key: KAFKA-8225 URL: https://issues.apache.org/jira/browse/KAFKA-8225 Project: Kafka Issue Type: Sub-task

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

2019-04-13 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8230: -- Summary: Add static membership support in librd consumer client Key: KAFKA-8230 URL: https://issues.apache.org/jira/browse/KAFKA-8230 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8236) Incorporate version control for Kafka Streams Application Reset

2019-04-15 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8236: -- Summary: Incorporate version control for Kafka Streams Application Reset Key: KAFKA-8236 URL: https://issues.apache.org/jira/browse/KAFKA-8236 Project: Kafka Is

[jira] [Commented] (KAFKA-8236) Incorporate version control for Kafka Streams Application Reset

2019-04-15 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16818487#comment-16818487 ] Boyang Chen commented on KAFKA-8236: [~mjsax] Right, this is just a preliminary thoug

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

2019-04-16 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8246: -- Summary: refactor topic/group instance id validation condition Key: KAFKA-8246 URL: https://issues.apache.org/jira/browse/KAFKA-8246 Project: Kafka Issue Type: I

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

2019-04-16 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819743#comment-16819743 ] Boyang Chen commented on KAFKA-8246: `boolean validChar = (c >= 'a' && c <= 'z') || (

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

2019-04-17 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16820708#comment-16820708 ] Boyang Chen commented on KAFKA-8246: Interesting, thanks for the info! [~sliebau] Cc

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

2019-04-19 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16822124#comment-16822124 ] Boyang Chen commented on KAFKA-8246: My second thought is that for `group.instance.id

[jira] [Created] (KAFKA-8285) Handle thread-id random switch on JVM for KStream

2019-04-24 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8285: -- Summary: Handle thread-id random switch on JVM for KStream Key: KAFKA-8285 URL: https://issues.apache.org/jira/browse/KAFKA-8285 Project: Kafka Issue Type: Sub-t

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

2019-04-24 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8284: -- Summary: Enable static membership on KStream Key: KAFKA-8284 URL: https://issues.apache.org/jira/browse/KAFKA-8284 Project: Kafka Issue Type: Sub-task

[jira] [Updated] (KAFKA-8285) Handle thread-id random switch on JVM for KStream

2019-04-24 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8285: --- Description: Currently we are potentially at risk by being bite for interleaving stream thread ids.

[jira] [Created] (KAFKA-8287) JVM global map to fence duplicate client id

2019-04-24 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8287: -- Summary: JVM global map to fence duplicate client id Key: KAFKA-8287 URL: https://issues.apache.org/jira/browse/KAFKA-8287 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8291: -- Summary: System test consumer_test.py failed on trunk Key: KAFKA-8291 URL: https://issues.apache.org/jira/browse/KAFKA-8291 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8291: --- Component/s: core consumer > System test consumer_test.py failed on trunk >

[jira] [Commented] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16826341#comment-16826341 ] Boyang Chen commented on KAFKA-8291: One learning: considering use open source versio

[jira] [Updated] (KAFKA-8291) System test consumer_test.py failed on trunk

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8291: --- Description: Looks like trunk is failing as for now  [https://jenkins.confluent.io/job/system-test-ka

[jira] [Resolved] (KAFKA-8287) JVM global map to fence duplicate client id

2019-04-25 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8287. Resolution: Invalid We don't want to do it for now because there are existing use cases where `cli

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

2019-04-26 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-7862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7862. Resolution: Fixed > Modify JoinGroup logic to incorporate group.instance.id change > --

[jira] [Resolved] (KAFKA-7903) Replace OffsetCommit request/response with automated protocol

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

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

2019-05-01 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8311: -- Summary: Better consumer timeout exception handling Key: KAFKA-8311 URL: https://issues.apache.org/jira/browse/KAFKA-8311 Project: Kafka Issue Type: Improvement

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

2019-05-01 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: Boyang Chen > Better consumer timeout exception handling >

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

2019-05-04 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: --- Summary: Handle conflicting static member id (was: handle conflicting static member id) > Handle co

[jira] [Created] (KAFKA-8331) Add system test for enabling static membership on KStream

2019-05-07 Thread Boyang Chen (JIRA)
Boyang Chen created KAFKA-8331: -- Summary: Add system test for enabling static membership on KStream Key: KAFKA-8331 URL: https://issues.apache.org/jira/browse/KAFKA-8331 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-8332) Regression in handling of JoinGroupRequest disallows deterministic protocol selection based on order of preference

2019-05-07 Thread Boyang Chen (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16835206#comment-16835206 ] Boyang Chen commented on KAFKA-8332: Thanks for the JIRA. I think there is an ongoing

[jira] [Resolved] (KAFKA-8196) Replace InitProducerId request/response with automated protocol

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

[jira] [Reopened] (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 reopened KAFKA-7830: > Convert Kafka RPCs to use automatically generated code >

[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

  1   2   3   4   5   6   7   8   9   10   >