clear query| facets| time Search criteria: .   Results from 1 to 10 from 32 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-9393] DeleteRecords may cause extreme lock contention for large partition directories - Kafka - [issue]
...DeleteRecords, frequently used by KStreams triggers a Log.maybeIncrementLogStartOffset call, calling kafka.log.ProducerStateManager.listSnapshotFiles which calls on th...    Author: Lucas Bradstreet , 2020-06-18, 16:22
[KAFKA-9359] Controller does not handle requests while broker is being shutdown - Kafka - [issue]
...When a broker is shutdown it first tries to go through a controlled shutdown, resigning leadership of its partitions and then it stops the socket server from processing requests and shuts do...    Author: Lucas Bradstreet , 2020-05-10, 16:23
[KAFKA-9946] KAFKA-9539/StopReplicaRequest deletePartition changes may cause premature topic deletion handling in controller - Kafka - [issue]
...It seems like does not handle StopReplicaRequest where deletePartition(s) is set to false correctly when anoth...    Author: Lucas Bradstreet , 2020-05-06, 02:10
[KAFKA-8125] Check for topic existence in CreateTopicsRequest prior to creating replica assignment - Kafka - [issue]
...Imagine the following pattern to ensure topic creation in an application: Attempt to create a topic with # partitions P and replication factor R.  If topic creation fails with TopicExistsExc...    Author: Lucas Bradstreet , 2020-05-02, 15:09
[KAFKA-9137] Maintenance of FetchSession cache causing FETCH_SESSION_ID_NOT_FOUND in live sessions - Kafka - [issue]
...We have recently seen cases where brokers end up in a bad state where fetch session evictions occur at a high rate (> 16 per second) after a roll. This increase in eviction rate included ...    Author: Lucas Bradstreet , 2020-04-18, 19:35
[KAFKA-9864] Avoid expensive QuotaViolationException usage - Kafka - [issue]
...QuotaViolationException generates stack traces and uses String.format in exception generation. QuotaViolationException is used for control flow and these costs add up even though the excepti...    Author: Lucas Bradstreet , 2020-04-15, 16:34
[KAFKA-9820] validateMessagesAndAssignOffsetsCompressed allocates batch iterator which is not used - Kafka - [issue]
...KAFKA-8106 added a new skip key/value iterator that reduces allocations in LogValidator it creat...    Author: Lucas Bradstreet , 2020-04-04, 17:10
[KAFKA-9626] Benchmark and optimize AclAuthorizer.acls() - Kafka - [issue]
...AclAuthorizer.acls creates unnecessary intermediate sets which are only iterated over when another set is created from this set....    Author: Lucas Bradstreet , 2020-03-02, 20:22
[KAFKA-8963] Benchmark and optimize incremental fetch session handler - Kafka - [issue]
...The FetchSessionHandler is a cause of high CPU usage in the replica fetcher for brokers with high partition counts. A jmh benchmark should be added and the incremental fetch session handling...    Author: Lucas Bradstreet , 2020-02-28, 16:03
[KAFKA-9577] Client encountering SASL_HANDSHAKE protocol version errors on 2.5 / trunk - Kafka - [issue]
...I am trying 2.5.0 with sasl turned on and my consumer and producer clients receive:org.apache.kafka.common.errors.UnsupportedVersionException: The SASL_HANDSHAKE protocol does not support ve...    Author: Lucas Bradstreet , 2020-02-22, 05:58