kafka

kafka copied to clipboard

KAFKA-17774: Adding capability to handle max fetch records in Share Fetch (KIP-932)

2

The PR adds capability to restrict the messages in Share Fetch. The max fetch records will be an additional way to limit the number of records sent from broker to...

apoorvmittal10

Client applications use SSL/TLS to connect with Kafka brokers in order to implement secured communication. The clients initiate SSL communication with Kafka brokers using the SSL Engine constructed from the...

rahulnirgude

Client applications use SSL/TLS to connect with Kafka brokers in order to implement secured communication. The clients initiate SSL communication with Kafka brokers using the SSL Engine constructed from the...

rahulnirgude

KAFKA-17339: LocalLogManager should support RaftClient#schedulePreparedAppend

1

Refer to [KAFKA-17339](https://issues.apache.org/jira/browse/KAFKA-17339) for more information. Enable the `LocalLogManager` class to really support prepared batches, improving the test implementation to more closely mimic the behavior of a real log manager(KafkaRaftClient)....

peterxcli

Remove Scala procedure syntax

8

This removes the Scala procedure syntax from the codebase as this is deprecated since Scala 2.11: https://github.com/scala/scala/pull/3076 Let me know your thoughts. ### Committer Checklist (excluded from commit message) -...

joan38

KAFKA-6846: Throw InterruptedException after poll in awaitReady() and sendAndReceive() if the interrupt flag is set

5

This PR resolves the issue that controller can spend a long time (more than 60s) in processing BrokerChange event when there are dead brokers, by throwing InterruptedException in the right...

hzxa21

KAFKA-1194 Forces unmapping of buffer if on Windows

2

In response to KAFKA-1194 issue, it now forces buffer to unmap if running on Windows OS. Invdividual Unit Test 'testChangeFileSuffixes' on LogSegmentTest.scala passes. but other file IO related unit tests...

mmanna-sapfgl

Fix small issue in comment

1

The comment seems not correct when I try to figure out how TimingWheel works *More detailed description of your change, if necessary. The PR title and PR message become the...

QuantumBear

KAFKA-6807: Inconsistent method name.

1

Change the method name "readTo" to "lesser". The method is named as "readTo", but the method will return the variable with lesses value. Thus, the name "readTo" is inconsistent with...

Kui-Liu

KAFKA-6757 Log runtime exception in case of server startup errors

2

Sometimes while running Kafka server inside tests of an upstream application it can happen that the server cannot start due to a bad runtime error, like a missing jar on...

eolivelli