[
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
>
[
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
>
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-8332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835206#comment-16835206
]
Boyang Chen commented on KAFKA-8332:
Thanks for the JIRA. I think there is an ongoing PR here:
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
[
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
[
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
>
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:
[
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
>
[
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
>
[
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
[
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://issues.apache.org/jira/browse/KAFKA-8291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16826341#comment-16826341
]
Boyang Chen commented on KAFKA-8291:
One learning: considering use open source version in default
[
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
>
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
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
[
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.
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:
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
[
https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16822124#comment-16822124
]
Boyang Chen commented on KAFKA-8246:
My second thought is that for `group.instance.id` this
[
https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16820708#comment-16820708
]
Boyang Chen commented on KAFKA-8246:
Interesting, thanks for the info! [~sliebau] Cc [~hachikuji]
>
[
https://issues.apache.org/jira/browse/KAFKA-8246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16819743#comment-16819743
]
Boyang Chen commented on KAFKA-8246:
`boolean validChar = (c >= 'a' && c <= 'z') || (c >= '0' && c <=
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:
[
https://issues.apache.org/jira/browse/KAFKA-8236?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16818487#comment-16818487
]
Boyang Chen commented on KAFKA-8236:
[~mjsax] Right, this is just a preliminary thought. One way we
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
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
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
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
[
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
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
[
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
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
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:
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
Boyang Chen created KAFKA-8019:
--
Summary: Better Scaling Experience for KStream
Key: KAFKA-8019
URL: https://issues.apache.org/jira/browse/KAFKA-8019
Project: Kafka
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-7995:
--
Assignee: Boyang Chen
> Augment singleton protocol type to list for Kafka Consumer
>
Boyang Chen created KAFKA-7995:
--
Summary: Augment singleton protocol type to list for Kafka
Consumer
Key: KAFKA-7995
URL: https://issues.apache.org/jira/browse/KAFKA-7995
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-7995:
--
Assignee: (was: Boyang Chen)
> Augment singleton protocol type to list for Kafka Consumer
Boyang Chen created KAFKA-7903:
--
Summary: Replace OffsetCommit request/response with automated
protocol
Key: KAFKA-7903
URL: https://issues.apache.org/jira/browse/KAFKA-7903
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7899.
Resolution: Invalid
It appears that the metadata should be generated by the client instead of
Boyang Chen created KAFKA-7899:
--
Summary: Command line tool to invalidate group metadata for clean
assignment
Key: KAFKA-7899
URL: https://issues.apache.org/jira/browse/KAFKA-7899
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7816.
Resolution: Won't Fix
Not a real use case
> Windowed topic should have window size as part of the
[
https://issues.apache.org/jira/browse/KAFKA-7859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-7859.
Resolution: Fixed
> Replace LeaveGroup request/response with automated protocol
>
[
https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-6995.
Resolution: Won't Fix
We are planning to deprecate this config with the introduction of KIP-345.
Boyang Chen created KAFKA-7862:
--
Summary: Modify JoinGroup logic to incorporate group.instance.id
change
Key: KAFKA-7862
URL: https://issues.apache.org/jira/browse/KAFKA-7862
Project: Kafka
Boyang Chen created KAFKA-7858:
--
Summary: Replace JoinGroup request/response with automated protocol
Key: KAFKA-7858
URL: https://issues.apache.org/jira/browse/KAFKA-7858
Project: Kafka
Issue
Boyang Chen created KAFKA-7859:
--
Summary: Replace LeaveGroup request/response with automated
protocol
Key: KAFKA-7859
URL: https://issues.apache.org/jira/browse/KAFKA-7859
Project: Kafka
Issue
Boyang Chen created KAFKA-7857:
--
Summary: Add AbstractCoordinatorConfig class to consolidate
consumer coordinator configs between Consumer and Connect
Key: KAFKA-7857
URL:
[
https://issues.apache.org/jira/browse/KAFKA-7853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-7853:
--
Assignee: Boyang Chen
> Refactor ConsumerCoordinator/AbstractCoordinator to reduce
Boyang Chen created KAFKA-7853:
--
Summary: Refactor ConsumerCoordinator/AbstractCoordinator to
reduce constructor parameter list
Key: KAFKA-7853
URL: https://issues.apache.org/jira/browse/KAFKA-7853
[
https://issues.apache.org/jira/browse/KAFKA-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16748373#comment-16748373
]
Boyang Chen commented on KAFKA-7816:
Yea, good point here [~guozhang], from the same windowed topic,
[
https://issues.apache.org/jira/browse/KAFKA-7816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16747680#comment-16747680
]
Boyang Chen commented on KAFKA-7816:
[~guozhang] [~mjsax] WDYT?
> Windowed topic should have window
[
https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743479#comment-16743479
]
Boyang Chen edited comment on KAFKA-7820 at 1/16/19 12:09 AM:
--
Thanks
[
https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16743479#comment-16743479
]
Boyang Chen commented on KAFKA-7820:
Thanks [~vinubarro] for more details. I think we need to further
[
https://issues.apache.org/jira/browse/KAFKA-7824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-7824:
---
Issue Type: Sub-task (was: Improvement)
Parent: KAFKA-7610
> Require member.id for initial
Boyang Chen created KAFKA-7824:
--
Summary: Require member.id for initial join group request
Key: KAFKA-7824
URL: https://issues.apache.org/jira/browse/KAFKA-7824
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-7820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16742549#comment-16742549
]
Boyang Chen commented on KAFKA-7820:
Hey Vinoth,
thanks for proposing this! Based on your use case,
Boyang Chen created KAFKA-7816:
--
Summary: Windowed topic should have window size as part of the
metadata
Key: KAFKA-7816
URL: https://issues.apache.org/jira/browse/KAFKA-7816
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738973#comment-16738973
]
Boyang Chen commented on KAFKA-7672:
Thanks for the thorough investigation and summary here
[
https://issues.apache.org/jira/browse/KAFKA-7806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738562#comment-16738562
]
Boyang Chen commented on KAFKA-7806:
Thanks John for bringing this up! FYI, [~shnguyen] has
[
https://issues.apache.org/jira/browse/KAFKA-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16737595#comment-16737595
]
Boyang Chen commented on KAFKA-7798:
Great speed!
> Expose embedded client context from KafkaStreams
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735422#comment-16735422
]
Boyang Chen commented on KAFKA-7672:
[~guozhang] Thanks for the explanation! It's a little bit
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16735067#comment-16735067
]
Boyang Chen commented on KAFKA-4835:
[~mjsax] Oh I thought I accidentally closed it before.
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reopened KAFKA-4835:
> Allow users control over repartitioning
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-4835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen resolved KAFKA-4835.
Resolution: Fixed
> Allow users control over repartitioning
>
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734504#comment-16734504
]
Boyang Chen commented on KAFKA-7672:
[~guozhang] Yes the second issue. So since
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16734415#comment-16734415
]
Boyang Chen commented on KAFKA-7672:
[~guozhang] Are you suggesting sth similar to this?
[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16733633#comment-16733633
]
Boyang Chen commented on KAFKA-7728:
[~guozhang]Thanks for the confirmation! [~mgharat] Do you want
[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730594#comment-16730594
]
Boyang Chen edited comment on KAFKA-7728 at 12/31/18 10:50 PM:
---
[~enether]
[
https://issues.apache.org/jira/browse/KAFKA-7725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730800#comment-16730800
]
Boyang Chen commented on KAFKA-7725:
Thanks [~astubbs] for sharing this issue. Will add this to the
[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16730594#comment-16730594
]
Boyang Chen commented on KAFKA-7728:
[~enether] Thanks for the thoughts! I think the compatibility
[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16729949#comment-16729949
]
Boyang Chen commented on KAFKA-7728:
Thanks Mayuresh for the great summary! Just pinging on this
[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16722715#comment-16722715
]
Boyang Chen commented on KAFKA-7728:
[~guozhang] [~mjsax] [~hachikuji] [~enether] Do you have time to
[
https://issues.apache.org/jira/browse/KAFKA-7728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-7728:
--
Assignee: Mayuresh Gharat
> Add JoinReason to the join group request for better rebalance
Boyang Chen created KAFKA-7728:
--
Summary: Add JoinReason to the join group request for better
rebalance handling
Key: KAFKA-7728
URL: https://issues.apache.org/jira/browse/KAFKA-7728
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702931#comment-16702931
]
Boyang Chen commented on KAFKA-7566:
I see your point. Feel free to close this Jira because I feel
[
https://issues.apache.org/jira/browse/KAFKA-7672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16698803#comment-16698803
]
Boyang Chen commented on KAFKA-7672:
Thanks Linyue for reporting and reproducing the bug! In fact, we
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-7610:
--
Assignee: Boyang Chen
> Detect consumer failures in initial JoinGroup
>
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-7610:
---
Component/s: consumer
> Detect consumer failures in initial JoinGroup
>
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16695627#comment-16695627
]
Boyang Chen commented on KAFKA-7610:
[~guozhang] [~hachikuji] Do you have any concern on 2)
[
https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692501#comment-16692501
]
Boyang Chen commented on KAFKA-7566:
[~guozhang] Yep, for example our KStream application publishes
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692496#comment-16692496
]
Boyang Chen edited comment on KAFKA-7641 at 11/20/18 12:52 AM:
---
[~enether]
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16692496#comment-16692496
]
Boyang Chen commented on KAFKA-7641:
[Stanislav
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690102#comment-16690102
]
Boyang Chen edited comment on KAFKA-7641 at 11/16/18 10:50 PM:
---
[~enether]
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16690102#comment-16690102
]
Boyang Chen commented on KAFKA-7641:
[~enether] Thanks! I think we need to propose two KIPs here: 1.
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen reassigned KAFKA-7641:
--
Assignee: Boyang Chen
> Add `consumer.group.max.size` to cap consumer metadata size on broker
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-7641:
---
Description:
In the JIRA discussion https://issues.apache.org/jira/browse/KAFKA-7610, Jason
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689925#comment-16689925
]
Boyang Chen commented on KAFKA-7641:
[~hachikuji] [~enether]
> Add `consumer.group.max.size` to cap
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-7641:
---
Description:
In the JIRA discussion https://issues.apache.org/jira/browse/KAFKA-7610, Jason
[
https://issues.apache.org/jira/browse/KAFKA-7641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-7641:
---
Summary: Add `consumer.group.max.size` to cap consumer metadata size on
broker (was: Add
Boyang Chen created KAFKA-7641:
--
Summary: Add `group.max.size` to cap group metadata on broker
Key: KAFKA-7641
URL: https://issues.apache.org/jira/browse/KAFKA-7641
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16689916#comment-16689916
]
Boyang Chen commented on KAFKA-7610:
Sounds good Jason! I think combining `group.max.size` and member
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16688332#comment-16688332
]
Boyang Chen edited comment on KAFKA-7610 at 11/15/18 4:44 PM:
--
Hey
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16687475#comment-16687475
]
Boyang Chen commented on KAFKA-7610:
Thanks [~guozhang] for jumping into the discussion! Just to
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685961#comment-16685961
]
Boyang Chen edited comment on KAFKA-7610 at 11/14/18 1:04 AM:
--
[~hachikuji]
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685961#comment-16685961
]
Boyang Chen commented on KAFKA-7610:
[~hachikuji] I see your point.
> a simple way to limit the
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16685810#comment-16685810
]
Boyang Chen commented on KAFKA-7610:
[~hachikuji] So we will still accept unknown member joining the
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Boyang Chen updated KAFKA-7610:
---
Comment: was deleted
(was: By saying failed on the way I mean a network timeout or some transit
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682509#comment-16682509
]
Boyang Chen edited comment on KAFKA-7610 at 11/10/18 5:18 PM:
--
Thanks Jason
[
https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682515#comment-16682515
]
Boyang Chen commented on KAFKA-7610:
By saying failed on the way I mean a network timeout or some
801 - 900 of 943 matches
Mail list logo
