[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465540#comment-16465540 ] Boyang Chen commented on KAFKA-6840: Sounds like a plan! I will start preparing a KIP and code for

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464310#comment-16464310 ] Boyang Chen commented on KAFKA-6840: Yep, forget to update. One more thing is that: public

[jira] [Updated] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

[ https://issues.apache.org/jira/browse/KAFKA-6896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-6896: --- Description: We would like to also export the producer metrics from {{StreamThread}} just like

[jira] [Created] (KAFKA-6896) add producer metrics exporting in KafkaStreams.java

Boyang Chen created KAFKA-6896: -- Summary: add producer metrics exporting in KafkaStreams.java Key: KAFKA-6896 URL: https://issues.apache.org/jira/browse/KAFKA-6896 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16464919#comment-16464919 ] Boyang Chen commented on KAFKA-6840: [~mjsax] thanks for the reply. I think I might mention the wrong

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505048#comment-16505048 ] Boyang Chen commented on KAFKA-6995: [~mjsax]thanks for the explanation! I realized that the config

[jira] [Created] (KAFKA-7018) persist memberId for consumer restart

Boyang Chen created KAFKA-7018: -- Summary: persist memberId for consumer restart Key: KAFKA-7018 URL: https://issues.apache.org/jira/browse/KAFKA-7018 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16506626#comment-16506626 ] Boyang Chen commented on KAFKA-6995: [~mjsax] That would be a viable solution. However, me as an end

[jira] [Commented] (KAFKA-7071) specify number of partitions when using repartition logic

[ https://issues.apache.org/jira/browse/KAFKA-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516326#comment-16516326 ] Boyang Chen commented on KAFKA-7071: [~mjsax] looks so, I will close this and reassign the ticket of

[jira] [Resolved] (KAFKA-7071) specify number of partitions when using repartition logic

[ https://issues.apache.org/jira/browse/KAFKA-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-7071. Resolution: Duplicate Dup with 6037 > specify number of partitions when using repartition logic >

[jira] [Assigned] (KAFKA-6037) Make Sub-topology Parallelism Tunable

[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-6037: -- Assignee: Boyang Chen > Make Sub-topology Parallelism Tunable >

[jira] [Commented] (KAFKA-6037) Make Sub-topology Parallelism Tunable

[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516329#comment-16516329 ] Boyang Chen commented on KAFKA-6037: I will take a look at it this week, thank you [~mjsax] for

[jira] [Comment Edited] (KAFKA-7018) persist memberId for consumer restart

[ https://issues.apache.org/jira/browse/KAFKA-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514939#comment-16514939 ] Boyang Chen edited comment on KAFKA-7018 at 6/17/18 12:06 AM: -- A summary of

[jira] [Commented] (KAFKA-7018) persist memberId for consumer restart

[ https://issues.apache.org/jira/browse/KAFKA-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16514939#comment-16514939 ] Boyang Chen commented on KAFKA-7018: A summary of the idea: When leader sends join request, it will

[jira] [Created] (KAFKA-7071) specify number of partitions when using repartition logic

Boyang Chen created KAFKA-7071: -- Summary: specify number of partitions when using repartition logic Key: KAFKA-7071 URL: https://issues.apache.org/jira/browse/KAFKA-7071 Project: Kafka Issue

[jira] [Updated] (KAFKA-7071) specify number of partitions when using repartition logic

[ https://issues.apache.org/jira/browse/KAFKA-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7071: --- Description: Hey there, I was wondering whether it makes sense to specify number of partitions of

[jira] [Commented] (KAFKA-6037) Make Sub-topology Parallelism Tunable

[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16516386#comment-16516386 ] Boyang Chen commented on KAFKA-6037: I took a quick look of KIP 221:

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505383#comment-16505383 ] Boyang Chen commented on KAFKA-6995: Thanks for the explanation, I understand the concern here. I

[jira] [Commented] (KAFKA-7018) persist memberId for consumer restart

[ https://issues.apache.org/jira/browse/KAFKA-7018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16505706#comment-16505706 ] Boyang Chen commented on KAFKA-7018: Thanks Guozhang! This could be done by our side, by persisting

[jira] [Created] (KAFKA-6986) Export Admin Client metrics through Stream Threads

Boyang Chen created KAFKA-6986: -- Summary: Export Admin Client metrics through Stream Threads Key: KAFKA-6986 URL: https://issues.apache.org/jira/browse/KAFKA-6986 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501418#comment-16501418 ] Boyang Chen commented on KAFKA-6986: Hey there, Of course! Feel free to reassign this to you and let

[jira] [Created] (KAFKA-6995) Make config "internal.leave.group.on.close" public

Boyang Chen created KAFKA-6995: -- Summary: Make config "internal.leave.group.on.close" public Key: KAFKA-6995 URL: https://issues.apache.org/jira/browse/KAFKA-6995 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-6986) Export Admin Client metrics through Stream Threads

[ https://issues.apache.org/jira/browse/KAFKA-6986?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16501921#comment-16501921 ] Boyang Chen commented on KAFKA-6986: [~shung] I think you need to get contributor access first.

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16502119#comment-16502119 ] Boyang Chen commented on KAFKA-6995: Original config was added here: 

[jira] [Comment Edited] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504209#comment-16504209 ] Boyang Chen edited comment on KAFKA-6995 at 6/7/18 4:00 AM: Basically leave

[jira] [Commented] (KAFKA-6995) Make config "internal.leave.group.on.close" public

[ https://issues.apache.org/jira/browse/KAFKA-6995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16504209#comment-16504209 ] Boyang Chen commented on KAFKA-6995: Basically leave group request will make the rebalance faster

[jira] [Created] (KAFKA-6840) support windowing in ktable API

Boyang Chen created KAFKA-6840: -- Summary: support windowing in ktable API Key: KAFKA-6840 URL: https://issues.apache.org/jira/browse/KAFKA-6840 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-6840: --- Labels: api (was: ) > support windowing in ktable API > --- > >

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16461659#comment-16461659 ] Boyang Chen commented on KAFKA-6840: Sounds good, I will give it a try [~mjsax] > support windowing

[jira] [Resolved] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-6657. Resolution: Delivered The code is merged: https://github.com/apache/kafka/pull/4805 > Add

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463297#comment-16463297 ] Boyang Chen commented on KAFKA-6840: [~mjsax] Sorry haven't updated this thread for a while. This is

[jira] [Commented] (KAFKA-6840) support windowing in ktable API

[ https://issues.apache.org/jira/browse/KAFKA-6840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16463304#comment-16463304 ] Boyang Chen commented on KAFKA-6840: I think alternatively we could extend class `Materialized` with

[jira] [Commented] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata

[ https://issues.apache.org/jira/browse/KAFKA-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16351866#comment-16351866 ] Boyang Chen commented on KAFKA-6381: [~mjsax] I did have a try on this one, and found that I could not

[jira] [Assigned] (KAFKA-6381) Improve KafkaStreamsTest for localThreadMetadata

[ https://issues.apache.org/jira/browse/KAFKA-6381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-6381: -- Assignee: (was: Boyang Chen) > Improve KafkaStreamsTest for localThreadMetadata >

[jira] [Commented] (KAFKA-6386) Deprecate KafkaStreams constructor taking StreamsConfig parameter

[ https://issues.apache.org/jira/browse/KAFKA-6386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16301556#comment-16301556 ] Boyang Chen commented on KAFKA-6386: Hi I'm new to Kafka repo and would like to contribute. Is there a

[jira] [Created] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

Boyang Chen created KAFKA-6723: -- Summary: Separate "max.poll.record" for restore consumer and common consumer Key: KAFKA-6723 URL: https://issues.apache.org/jira/browse/KAFKA-6723 Project: Kafka

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16416749#comment-16416749 ] Boyang Chen commented on KAFKA-6723: [~guozhang] [~liquanpei] [~mjsax] Thoughts on this? > Separate

[jira] [Commented] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16418337#comment-16418337 ] Boyang Chen commented on KAFKA-6657: [~guozhang]thanks Guozhang! I will take a look at this one. >

[jira] [Assigned] (KAFKA-6657) Add StreamsConfig prefix for different consumers

[ https://issues.apache.org/jira/browse/KAFKA-6657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-6657: -- Assignee: Boyang Chen > Add StreamsConfig prefix for different consumers >

[jira] [Commented] (KAFKA-6723) Separate "max.poll.record" for restore consumer and common consumer

[ https://issues.apache.org/jira/browse/KAFKA-6723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16417697#comment-16417697 ] Boyang Chen commented on KAFKA-6723: [~mjsax]  [~guozhang] I haven't seen a concrete design for 

[jira] [Updated] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only

[ https://issues.apache.org/jira/browse/KAFKA-7566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-7566: --- Priority: Minor (was: Major) Component/s: streams > Add sidecar job to leader (or a random

[jira] [Created] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only

Boyang Chen created KAFKA-7566: -- Summary: Add sidecar job to leader (or a random single follower) only Key: KAFKA-7566 URL: https://issues.apache.org/jira/browse/KAFKA-7566 Project: Kafka

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ https://issues.apache.org/jira/browse/KAFKA-7610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16682509#comment-16682509 ] Boyang Chen commented on KAFKA-7610: Thanks Jason for proposing this issue. I think in static

[jira] [Issue Comment Deleted] (KAFKA-7610) 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: --- Comment: was deleted (was: By saying failed on the way I mean a network timeout or some transit

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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]

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Comment Edited] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Assigned] (KAFKA-7641) 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 reassigned KAFKA-7641: -- Assignee: Boyang Chen > Add `consumer.group.max.size` to cap consumer metadata size on broker

[jira] [Updated] (KAFKA-7641) 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: --- Summary: Add `consumer.group.max.size` to cap consumer metadata size on broker (was: Add

[jira] [Updated] (KAFKA-7641) 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

[jira] [Commented] (KAFKA-7610) Detect consumer failures in initial JoinGroup

[ 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

[jira] [Commented] (KAFKA-7641) 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:comment-tabpanel=16689925#comment-16689925 ] Boyang Chen commented on KAFKA-7641: [~hachikuji] [~enether] > Add `consumer.group.max.size` to cap

[jira] [Updated] (KAFKA-7641) 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

[jira] [Created] (KAFKA-7641) Add `group.max.size` to cap group metadata on broker

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:

[jira] [Commented] (KAFKA-7641) 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:comment-tabpanel=16690102#comment-16690102 ] Boyang Chen commented on KAFKA-7641: [~enether] Thanks! I think we need to propose two KIPs here: 1.

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

[ 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]

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

[ 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

[jira] [Commented] (KAFKA-4835) Allow users control over repartitioning

[ 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.

[jira] [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 reopened KAFKA-4835: > Allow users control over repartitioning > --- > >

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ 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

[jira] [Created] (KAFKA-7824) Require member.id for initial join group request

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:

[jira] [Updated] (KAFKA-7824) Require member.id for initial join group request

[ 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

[jira] [Commented] (KAFKA-7820) distinct count kafka streams api

[ 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,

[jira] [Commented] (KAFKA-7820) distinct count kafka streams api

[ 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

[jira] [Comment Edited] (KAFKA-7820) distinct count kafka streams api

[ 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

[jira] [Commented] (KAFKA-7816) Windowed topic should have window size as part of the metadata

[ 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,

[jira] [Commented] (KAFKA-7816) Windowed topic should have window size as part of the metadata

[ 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

[jira] [Created] (KAFKA-7857) Add AbstractCoordinatorConfig class to consolidate consumer coordinator configs between Consumer and Connect

Boyang Chen created KAFKA-7857: -- Summary: Add AbstractCoordinatorConfig class to consolidate consumer coordinator configs between Consumer and Connect Key: KAFKA-7857 URL:

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

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

[jira] [Created] (KAFKA-7859) Replace LeaveGroup request/response with automated protocol

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

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

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

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

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

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

[ 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

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

[ 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

[jira] [Commented] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only

[ 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

[jira] [Commented] (KAFKA-7641) 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:comment-tabpanel=16692496#comment-16692496 ] Boyang Chen commented on KAFKA-7641: [Stanislav

[jira] [Comment Edited] (KAFKA-7641) 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:comment-tabpanel=16692496#comment-16692496 ] Boyang Chen edited comment on KAFKA-7641 at 11/20/18 12:52 AM: --- [~enether]

[jira] [Commented] (KAFKA-7566) Add sidecar job to leader (or a random single follower) only

[ 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

[jira] [Assigned] (KAFKA-7610) 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 reassigned KAFKA-7610: -- Assignee: Boyang Chen > Detect consumer failures in initial JoinGroup >

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ 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

[jira] [Commented] (KAFKA-7610) 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)

[jira] [Updated] (KAFKA-7610) 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 >

[jira] [Comment Edited] (KAFKA-7641) 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:comment-tabpanel=16690102#comment-16690102 ] Boyang Chen edited comment on KAFKA-7641 at 11/16/18 10:50 PM: --- [~enether]

[jira] [Commented] (KAFKA-7798) Expose embedded client context from KafkaStreams threadMetadata

[ 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

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ 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

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ 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? 

[jira] [Commented] (KAFKA-7672) The local state not fully restored after KafkaStream rebalanced, resulting in data loss

[ 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

[jira] [Resolved] (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 >

[jira] [Created] (KAFKA-7816) Windowed topic should have window size as part of the metadata

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

[jira] [Commented] (KAFKA-7725) Add a delay for further CG rebalances, beyond KIP-134 group.initial.rebalance.delay.ms

[ 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

[jira] [Commented] (KAFKA-7806) Windowed Aggregations should wrap default key serde if none is specified

[ 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

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

[ 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

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

[ 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

[jira] [Created] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list

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

[jira] [Assigned] (KAFKA-7853) Refactor ConsumerCoordinator/AbstractCoordinator to reduce constructor parameter list

[ 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

[jira] [Created] (KAFKA-8019) Better Scaling Experience for KStream

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

  1   2   3   4   5   6   7   8   9   10   >