Boyang Chen created KAFKA-8555:
--
Summary: Flaky test
ExampleConnectIntegrationTest#testSourceConnector
Key: KAFKA-8555
URL: https://issues.apache.org/jira/browse/KAFKA-8555
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-3556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16866189#comment-16866189
]
Boyang Chen commented on KAFKA-3556:
[~guozhang] Sounds good, I found the rebalance d
[
https://issues.apache.org/jira/browse/KAFKA-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7853.
Resolution: Fixed
> Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor
> param
[
https://issues.apache.org/jira/browse/KAFKA-3556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16865265#comment-16865265
]
Boyang Chen commented on KAFKA-3556:
[~guozhang] [~hachikuji] What do you think? Righ
[
https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8510:
---
Component/s: consumer
> Update StreamsPartitionAssignor to use the built-in owned partitions to
> ac
Boyang Chen created KAFKA-8541:
--
Summary: Flakey test LeaderElectionCommandTest#testTopicPartition
Key: KAFKA-8541
URL: https://issues.apache.org/jira/browse/KAFKA-8541
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16863604#comment-16863604
]
Boyang Chen commented on KAFKA-8073:
[https://builds.apache.org/job/kafka-pr-jdk11-sc
[
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
[
https://issues.apache.org/jira/browse/KAFKA-8108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-8108:
---
Comment: was deleted
(was: [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/5516/consoleFull]
[
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
> --
[
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
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
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
[
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
> -
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:
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
[
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
>
[
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
[
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
[
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
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
[
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
Boyang Chen created KAFKA-8502:
--
Summary: Flakey test
AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions
Key: KAFKA-8502
URL: https://issues.apache.org/jira/browse/KAFKA-8502
Project: Kaf
[
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
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
[
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
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
[
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
>
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
[
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
> --
[
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
[
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
[
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
[
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
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
Boyang Chen created KAFKA-8461:
--
Summary: Flakey test
UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride
Key: KAFKA-8461
URL: https://issues.apache.org/jira/browse/KAFKA-8461
Proj
[
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*
Boyang Chen created KAFKA-8460:
--
Summary: Flaky Test
PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition
Key: KAFKA-8460
URL: https://issues.apache.org/jira/browse/KAFKA-8460
Project: Kafka
[
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
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
Boyang Chen created KAFKA-8456:
--
Summary: Flaky Test
StoreUpgradeIntegrationTest#shouldMigratePersistentWindowStoreToTimestampedWindowStoreUsingPapi
Key: KAFKA-8456
URL: https://issues.apache.org/jira/browse/KAFKA-8
[
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
[
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:
-
[
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:
-
[
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
[
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
[
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
> --
[
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
> --
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
[
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
>
[
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
[
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
Boyang Chen created KAFKA-8445:
--
Summary: Flaky Test
UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride
Key: KAFKA-8445
URL: https://issues.apache.org/jira/browse/KAFKA-8445
Proj
[
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
[
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
[
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
[
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
> -
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
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
[
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
[
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
[
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
> ---
[
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
>
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
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:
[
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
> --
[
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
[
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
[
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
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
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
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
[
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:
-
[
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!
[
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
> ---
>
>
[
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
>
[
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
> -
[
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
> ---
>
>
[
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
[
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
> ---
>
>
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
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
[
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
> --
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
[
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:
[
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
> -
[
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
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
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
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
[
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
> --
[
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
[
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:
-
701 - 800 of 958 matches
Mail list logo