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...
http://issues.apache.org/jira/browse/KAFKA-9455    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...
http://issues.apache.org/jira/browse/KAFKA-1592    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...
http://issues.apache.org/jira/browse/KAFKA-5676    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...
http://issues.apache.org/jira/browse/KAFKA-967    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...
http://issues.apache.org/jira/browse/KAFKA-4117    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 ...
http://issues.apache.org/jira/browse/KAFKA-9821    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...
http://issues.apache.org/jira/browse/KAFKA-10005    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...
http://issues.apache.org/jira/browse/KAFKA-1056    Author: Guozhang Wang , 2020-05-21, 00:05