kafka

kafka copied to clipboard

KAFKA-6559: Iterate record sets before calling Log.append

2

If a Produce request contains multiple record sets for a single topic-partition, it is better to iterate these before calling Log.append. This is because append will process all the sets...

toddpalino

MINOR: UpdateMetadataRequest should be lazily created

9

We should defer to construct UpdateMetadataRequest Builder to the right time when we really need them. *More detailed description of your change, if necessary. The PR title and PR message...

huxihx

Dynamically reload truststore.

1

This RP allows kafka brokers to dynamically reload truststore based on last modify time of the truststore file. No need to run AdminClient/kafka-configs.sh.

allenxiang

[KAFKA-6482] when produce send a invalidity timestamps, broker will be not delete …

3

when produce send a invalidity timestamps, broker will be not delete files forever... https://issues.apache.org/jira/browse/KAFKA-6482

leonhong

KAFKA-6303: Potential lack of synchronization in NioEchoServer

1

In the run() method: SocketChannel socketChannel = ((ServerSocketChannel) key.channel()).accept(); socketChannel.configureBlocking(false); newChannels.add(socketChannel); Modification to newChannels should be protected by synchronized block. - [ ] Verify design and implementation - [x] Verify...

shivsantham

KAFKA-6326: when broker is unavailable, fast revover

4

- when broker is unavailable(such as broker's machine is down), controller will wait 30 sec timeout by dedault. it seems to be that the timeout waiting is not necessary. It...

leonhong

Remove ignore-case grep option from kafka-server-stop.sh

1

In order to avoid killing kafka-manager running on the same machine, because it will match these strings from command line: lib/org.apache.kafka.kafka_2.11-0.10.0.1.jar lib/org.apache.kafka.kafka-clients-0.10.0.1.jar *More detailed description of your change, if necessary....

sm4rk0

KAFKA-4893: Fix conflict between async topic deletion and max topic length

7

With async topic deletion the topic partition folder name is affixed with a '.', a UUID, and '-delete'. If topic name length is close to its current limit (249) this...

vahidhashemian

KAFKA-17526: make ConfigCommandIntegrationTest.java test use correct arguments in testing alias

3

JIRA: [KAFKA-17526](https://issues.apache.org/jira/browse/KAFKA-17526) This PR reviews existing tests and refactors the validation to ensure the command is generated correctly. ### Committer Checklist (excluded from commit message) - [ ] Verify design...

frankvicky

KAFKA-16907: Fix RaftUtil's type complexity

2

JIRA: [KAFKA-16907](https://issues.apache.org/jira/browse/KAFKA-16907) This PR aims to fix the `ClassDataAbstractionCoupling` and `ClassFanOutComplexity` issues in `RaftUtils`. `RaftUtils` will be split into several classes, each based on a specific RPC in the Raft...

frankvicky