[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] [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-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-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] [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-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] [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] [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] [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] [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-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] [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] [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=16505048#comment-16505048 ] Boyang Chen commented on KAFKA-6995: [~mjsax]thanks for the explanation! I realized that the config

[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] [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] [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] [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=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-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] [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=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=16464919#comment-16464919 ] Boyang Chen commented on KAFKA-6840: [~mjsax] thanks for the reply. I think I might mention the wrong

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

<    5   6   7   8   9   10