Chris Egerton

Possible token refresh race condition with streams

1

Hi @mattbdean, just want to start by saying I really enjoy the library you've written here and it's saved me a lot of work for my own project, a Reddit...

MINOR: Stop leaking threads in BlockingConnectorTest

4

These tests currently create threads that block forever until the JVM is shut down. This change unblocks those threads once their respective test cases are finished. This is valuable not...

MINOR: Remove unused ShutdownableThread class and ineffective ThreadedTest classes

2

The `ShutdownableThread` class isn't used anywhere outside of tests, and the `ThreadedTest` class only works in cases where the logic that's being tested uses a `ShutdownableThread`. Both of these classes...

KAFKA-14143: Exactly-once source connector system tests (KIP-618)

11

Implements system tests for [KIP-618](https://cwiki.apache.org/confluence/display/KAFKA/KIP-618%3A+Exactly-Once+Support+for+Source+Connectors). Relies on changes from: - https://github.com/apache/kafka/pull/11782

[Jira](https://issues.apache.org/jira/browse/KAFKA-14101) Depends on https://github.com/apache/kafka/pull/12429, which should implement a logical fix for KAFKA-14101. This follow-up PR is intended to help harden our integration tests against the mistakes that caused KAFKA-14101 by:...

KAFKA-13533: Clean up resources on failed connector and task startup

1

[Jira](https://issues.apache.org/jira/browse/KAFKA-13533) Introduces and leverages a new `Closeables` utility class that can be used to track accrued `AutoCloseable` objects via a try-with-resources block. Also switches the `Worker` class over to use...

KAFKA-12497: Skip periodic offset commits for failed source tasks

15

[Jira](https://issues.apache.org/jira/browse/KAFKA-12497) This change serves two purposes: 1. Eliminate unnecessary log messages for offset commit of tasks that don't need to perform offset commits (e.g., a task that has failed and...

KAFKA-13764: Improve balancing algorithm for Connect incremental rebalancing

5

[Jira](https://issues.apache.org/jira/browse/KAFKA-13764) Depends on https://github.com/apache/kafka/pull/11983 The primary goal of this PR is to address several outstanding issues with incremental rebalancing that lead to stable-but-unbalanced clusters. However, other small bug fixes are...

KAFKA-14058: Migrate ExactlyOnceWorkerSourceTaskTest from EasyMock and PowerMock to Mockito

3

[Jira](https://issues.apache.org/jira/browse/KAFKA-14058) Some notes: 1. Introduced new `ConcurrencyUtils` and `MockitoUtils` classes for reusable testing logic that will likely be used in the near future for [KAFKA-14059](https://issues.apache.org/jira/browse/KAFKA-14059) and [KAFKA-14060](https://issues.apache.org/jira/browse/KAFKA-14060). 2. Refactored a...

KAFKA-14021: Implement new KIP-618 APIs in MirrorSourceConnector

1

[Jira](https://issues.apache.org/jira/browse/KAFKA-14021) Implements the new `SourceConnector::exactlyOnceSupport` method in the source connector used by MirrorMaker 2. Since the connector tracks offsets using the Kafka Connect framework, exactly-once support is possible. However, we...