clear query| facets| time Search criteria: .   Results from 1 to 10 from 62 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-9455] Consider using TreeMap for in-memory stores of Streams - Kafka - [issue]
...From Sophie Blee-Goldman: It's worth noting that it might be a good idea to switch to TreeMap for different reasons. Right now the ConcurrentSkipListMap allows us to safely perform range que...    Author: Guozhang Wang , 2020-05-29, 19:43
[KAFKA-1592] Some INFO level logging needs to be DEBUG - Kafka - [issue]
...Some of the INFO level log4j entries are not really useful, for example in SocketServer.Processor, due to metadata requests that reply on a separate and short-lived socket, the following log...    Author: Guozhang Wang , 2020-05-28, 18:28
[expand - 1 more] - NEED HELP : OutOfMemoryError: Java heap space error while starting KafkaStream with a simple topology - Kafka - [mail # user]
...Thanks for the update Pushkar! I'd have to say it is indeed very verymisleading error message and we should fix it asap. Will follow-up on theticket.GuozhangOn Thu, May 28, 2020 at 9:17 AM J...
   Author: Guozhang Wang , 2020-05-28, 16:35
[VOTE] KIP-589: Add API to update Replica state in Controller - Kafka - [mail # dev]
...David, thanks for the KIP. I'm +1 on it as well.One note is that in post-ZK world, we would need a different way to getbroker epoch since it is updated as ZKversion today. I believe we would...
   Author: Guozhang Wang , 2020-05-28, 16:34
[KAFKA-5676] MockStreamsMetrics should be in o.a.k.test - Kafka - [issue]
...MockStreamsMetrics's package should be `o.a.k.test` not `o.a.k.streams.processor.internals`. In addition, it should not require a Metrics parameter in its constructor as it is only needed fo...    Author: Guozhang Wang , 2020-05-27, 22:49
[KAFKA-967] Use key range in ProducerPerformance - Kafka - [issue]
...Currently in ProducerPerformance, the key of the message is set to MessageID. It would better to set it to a specific key within a key range (Integer type) so that we can test the semantic p...    Author: Guozhang Wang , 2020-05-27, 21:07
[KAFKA-4117] Cleanup StreamPartitionAssignor behavior - Kafka - [issue]
...I went through the whole assignment logic once again and I feel the logic has now becomes a bit lossy, and I want to clean them up probably in another PR but just dump my thoughts here on th...    Author: Guozhang Wang , 2020-05-26, 22:19
[KAFKA-9821] Partition may skip assignment with static members and incremental rebalances - Kafka - [issue]
...When static membership (KIP-345) and incremental rebalancing (KIP-429) are turned on at the same time, that upon failure it is possible some partitions are not assigned to anyone. The event ...    Author: Guozhang Wang , 2020-05-26, 18:03
[KAFKA-10005] Decouple RestoreListener from RestoreCallback and not enable bulk loading for RocksDB - Kafka - [issue]
...In Kafka Streams we have two restoration callbacks: RestoreCallback (BatchingRestoreCallback): specified per-store via registration to specify the logic of applying a batch of records read f...    Author: Guozhang Wang , 2020-05-22, 19:11
[KAFKA-1056] Evenly Distribute Intervals in OffsetIndex - Kafka - [issue]
...Today a new entry will be created in OffsetIndex for each produce request regardless of the number of messages it contains. It is better to evenly distribute the intervals between index entr...    Author: Guozhang Wang , 2020-05-21, 00:05