clear query| facets| time Search criteria: .   Results from 1 to 10 from 279 (0.0s).
Loading phrases to help you
refine your search...
[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
[expand - 3 more] - [DISCUSS] KIP-609: Use Pre-registration and Blocking Calls for Better Transaction Efficiency - Kafka - [mail # dev]
...Just to clarify on the implementation details: today insideSender#runOnce(), we have the following:```if (maybeSendAndPollTransactionalRequest()) {    return;}```Which basically me...
   Author: Guozhang Wang , 2020-05-20, 22:27