clear query| facets| time Search criteria: .   Results from 1 to 10 from 46 (0.0s).
Loading phrases to help you
refine your search...
[DISCUSS] KIP-540: Implement per key stream time tracking - Kafka - [mail # dev]
...Hi all,After some thought, I thought that we could move forward with this KIP. Thelow traffic suppression buffer issue is not necessarily a blocker issue,since there areways to mitigate the ...
   Author: Richard Yu , 2019-11-10, 19:43
[expand - 3 more] - [DISCUSS] KIP-539: Implement mechanism to flush out records in low volume suppression buffers - Kafka - [mail # dev]
...Hi John,Reading the KIP over, I actually think that this will be anexcellent extension to what we have now.I've read the discussion for that KIP and it looks like Jonathan nevermentioned how...
   Author: Richard Yu , 2019-10-22, 23:10
[expand - 5 more] - [VOTE] KIP-534: Retain tombstones for approximately delete.retention.ms milliseconds - Kafka - [mail # dev]
...Hi all,Seeing that we got all out votes needed with 3 binding votes and 0nonbinding.I consider this KIP passed.Cheers,RichardOn Fri, Oct 18, 2019 at 9:17 AM Guozhang Wang  wrote:> Th...
   Author: Richard Yu , 2019-10-18, 21:26
[expand - 4 more] - [DISCUSS] KIP-515: Reorganize checkpoint system in log cleaner to be per partition - Kafka - [mail # dev]
...Hi Jun, Jason,I've updated the KIP accordingly.Sorry for taking a while to get back to you guys.We should've ironed out the general approach fairly well now.So if there isn't any other comme...
   Author: Richard Yu , 2019-10-12, 18:08
[KAFKA-7850] Remove deprecated KStreamTestDriver - Kafka - [issue]
...Eversince a series of new test improvements were made to KafkaStreams test suite, KStreamTestDriver was deprecated in favor of TopologyTestDriver. However, a couple existing unit tests conti...
http://issues.apache.org/jira/browse/KAFKA-7850    Author: Richard Yu , 2019-07-17, 16:28
[expand - 10 more] - KIP-457: Add DISCONNECTED state to Kafka Streams - Kafka - [mail # dev]
...Hi Matthias and Hachikuji,Sorry for getting back to you so late. Currently on a trip, so I hadn't got the time to respond.Currently, I'm not sure which approach we should do ATM, considering...
   Author: Richard Yu , 2019-06-27, 23:37
[KAFKA-8516] Consider allowing all replicas to have read/write permissions - Kafka - [issue]
...Currently, in Kafka internals, a leader is responsible for all the read and write operations requested by the user. This naturally incurs a bottleneck since one replica, as the leader, would...
http://issues.apache.org/jira/browse/KAFKA-8516    Author: Richard Yu , 2019-06-11, 06:16
[KAFKA-8438] Add API to allow user to define end behavior of consumer failure - Kafka - [issue]
...Recently, in a concerted effort to make Kafka's rebalances less painful, various approaches has been used to reduce the number of and impact of rebalances. Often, the trigger of a rebalance ...
http://issues.apache.org/jira/browse/KAFKA-8438    Author: Richard Yu , 2019-06-05, 20:08
[expand - 1 more] - [DISCUSS] KIP-472: Add header to RecordContext - Kafka - [mail # dev]
...Hi Matthias,Thanks for responding. :)I suppose from the scope of the change that is needed to fix the timestamppropagation bug is too complex (in other words, probably not worth it).So shoul...
   Author: Richard Yu , 2019-05-31, 23:20
[KAFKA-8434] Make global stream time consistent over all stream tasks - Kafka - [issue]
http://issues.apache.org/jira/browse/KAFKA-8434    Author: Richard Yu , 2019-05-26, 21:31