clear query| facets| time Search criteria: .   Results from 1 to 10 from 42 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-6840] support windowing in ktable API - Kafka - [issue]
...The StreamsBuilder provides table() API to materialize a changelog topic into a local key-value store (KTable), which is very convenient. However, current underlying implementation does not ...
http://issues.apache.org/jira/browse/KAFKA-6840    Author: Boyang Chen , 2018-08-31, 18:30
[expand - 8 more] - [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id - Kafka - [mail # dev]
...Thanks Matthias for the input. Sorry I was busy recently and haven't got time to update this thread. To summarize what we come up so far, here is a draft updated plan:Introduce a new config ...
   Author: Boyang Chen , 2018-08-21, 05:13
[expand - 2 more] - Stream config in StreamPartitionAssignor - Kafka - [mail # dev]
...Sounds good. I will take a look at the doc and get back to you!________________________________From: Guozhang Wang Sent: Wednesday, July 11, 2018 2:07 AMTo: devSubject: Re: Stream config in ...
   Author: Boyang Chen , 2018-07-10, 21:33
Customizing initial consumer group rebalance delay - Kafka - [mail # dev]
...Hey there,I have a question regarding KIP-134. Basically this config `group.initial.rebalance.delay.ms` is set on broker side to delay the initial rebalance of consumer groups. For certain c...
   Author: Boyang Chen , 2018-07-02, 01:45
[KAFKA-6986] Export Admin Client metrics through Stream Threads - Kafka - [issue]
...We already exported producer and consumer metrics through KafkaStreams class:https://github.com/apache/kafka/pull/4998It makes sense to also export the Admin client metrics.If any new contri...
http://issues.apache.org/jira/browse/KAFKA-6986    Author: Boyang Chen , 2018-06-29, 20:27
[KAFKA-7071] specify number of partitions when using repartition logic - Kafka - [issue]
...Hey there, I was wondering whether it makes sense to specify number of partitions of the output topic from a repartition operation like groupBy, flatMap, etc. The current DSL doesn't support...
http://issues.apache.org/jira/browse/KAFKA-7071    Author: Boyang Chen , 2018-06-18, 20:52
[KAFKA-7018] persist memberId for consumer restart - Kafka - [issue]
...In group coordinator, there is a logic to neglect join group request from existing follower consumers:case Empty | Stable =>  if (memberId == JoinGroupRequest.UNKNOWN_MEMBER_ID) {&nb...
http://issues.apache.org/jira/browse/KAFKA-7018    Author: Boyang Chen , 2018-06-17, 00:06
[KAFKA-6995] Make config "internal.leave.group.on.close" public - Kafka - [issue]
...We are proposing to make the config "internal.leave.group.on.close" public. The reason is that for heavy state application the sticky assignment won't work because each stream worker will le...
http://issues.apache.org/jira/browse/KAFKA-6995    Author: Boyang Chen , 2018-06-08, 22:08
[expand - 1 more] - [DISCUSSION] KIP-300: Add Windowed KTable API in StreamsBuilder - Kafka - [mail # dev]
...Hey friends,I know this is critical time for the 2.0 release. Just want to call out again for further review on the API format. Any feedback would be appreciated, thank you!Boyang___________...
   Author: Boyang Chen , 2018-05-25, 05:39
[KAFKA-6896] add producer metrics exporting in KafkaStreams.java - Kafka - [issue]
...We would like to also export the producer metrics from StreamThread just like consumer metrics, so that we could gain more visibility of stream application. The approach is to pass in the {{...
http://issues.apache.org/jira/browse/KAFKA-6896    Author: Boyang Chen , 2018-05-15, 21:29