kafka

kafka copied to clipboard

KAFKA 5609 - Added RollingFileAppender as per review comments

4

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...

asutosh936

MINOR: clarify ProducerPerformance throughput units

2

### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including...

cburroughs

KAFKA-6700; allow producer performance test to run for a fixed duration

1

### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including...

cburroughs

KAFKA-6649: Should catch OutOfRangeException for ReplicaFetcherThread

5

https://issues.apache.org/jira/browse/KAFKA-6649 `AbstractFetcherThread.processFetchRequest` should catch OffsetOutOfRangeException lest the thread was forcibly stopped. *More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message,...

huxihx

[WIP] KAFKA-6589 Extract Heartbeat thread from AbstractCoordinator

7

AbstractCoordinator interacts with the thread via a HeartbeatThreadManager. The existing behavior was extracted to an abstract class + some glue code in the AbstractCoordinator. Testing was done using the existing...

smurakozi

KAFKA-6588: Add metric for alive log cleaner thread count

3

This patch introduces a Log Cleaner metric - `live-cleaner-thread-count` to monitor the log cleaner thread. It additionally fixes a minor issue to ensure that the correct offsets are logged in...

navina

KAFKA-6581: Fix the ConsumerGroupCommand indefinite execution if one of the partition is unavailable.

2

* Checks if partition available before calling consumer.position * Adds timeout on consumer.position() call. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [...

SahilAggarwal

KAFKA-6332: Kafka system tests should use nc instead of log grep to d…

12

…etect start-up - Extracted a new function (listening) in system test utils module to test whether a specified port on a specified node is listening for connections. - Refactored system...

asasvari

MINOR: use bash regex matching instead of egrep inside kafka-run-class.sh

2

It seems there is no reason to call egrep for each including jar since bash support regex matching. The reason of why this change might be useful is that we...

kurnevsky

KAFKA-5285: Use window and session key schema's comparator for rocksDB / Cache bytes [WIP]

1

*More detailed description of your change, if necessary. The PR title and PR message become the squashed commit message, so use a separate comment to ping reviewers.* *Summary of testing...

guozhangwang