kafka
kafka copied to clipboard
linkedin
Mirror of Apache Kafka
TICKET = [LIKAFKA-58549](https://jira01.corp.linkedin.com:8443/browse/LIKAFKA-58549) LI_DESCRIPTION = When a broker sends ControlledShutdown request to the controller, the controller will move the leaders from that broker to other replicas (this would involve leader...
This PR removes the overly strict key.password check when creating a `PEM` keystore. It's okay to pass no password for PEM-formatted keystore file. [Kafka 3.3](https://github.com/apache/kafka/blob/3.3/clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java#L288) removed this erroneous condition. ###...
TICKET = N/A LI_DESCRIPTION = Exclude logback as a dependency as the assumption is that log4j will be used. Tested the change with a info level logging in one of...
Log client endpoint when accept connections. This is for debugging purpose when there is a connection burst issue. After pulling in this change, I'm planning to add a new log...
BUGS=[LIKAFKA-53165](https://jira01.corp.linkedin.com:8443/browse/LIKAFKA-53165) This PR is implemented based on https://docs.google.com/document/d/1oSsI7-9udDTnqlN293T-6ajokRr8eM93QIzuu6iA__c/edit#heading=h.hmogsghmufas. After test with the fix the produce delay is still high during deployment. The explanations and more details can be found in:...
This patch adds QuotaBound sensor and QuotaUtilization sensor, in addition to the existing byte-rate & throttle-count sensors. The QuotaBound sensor records the value of of `org.apache.kafka.common.metrics.Quota#bound` if it exists. This...
TICKET = N/A LI_DESCRIPTION = Add comment to explain the safety of the brokerEpochSupplier method EXIT_CRITERIA = N/A *More detailed description of your change, if necessary. The PR title and...
[LI-HOTFIX] TICKET = LIKAFKA-43625 LI_DESCRIPTION = We want to re-use memory buffers for request deserialization. To do this, we need to gather statistics on the most frequent allocation sizes on...
(This is an updated version of https://github.com/linkedin/kafka/pull/275 with a key fix by Lucas to move the UMR-forwarding logic into the ControllerEvent thread, plus some log improvements, etc., and a small...
