This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch 2.0
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 111176d KAFKA-8340, KAFKA-8819: Use PluginClassLoader while statically initializing
plugins (#7315)
add b09b8fa KAFKA-9051: Prematurely complete source offset read requests for stopped
tasks (#7532)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/connect/runtime/Worker.java | 4 +-
.../kafka/connect/runtime/WorkerSourceTask.java | 12 +-
.../storage/CloseableOffsetStorageReader.java | 24 +-
.../connect/storage/KafkaOffsetBackingStore.java | 7 +-
.../connect/storage/MemoryOffsetBackingStore.java | 6 +-
.../kafka/connect/storage/OffsetBackingStore.java | 8 +-
.../connect/storage/OffsetStorageReaderImpl.java | 51 ++++-
.../connect/util/ConvertingFutureCallback.java | 58 ++++-
.../connect/runtime/ErrorHandlingTaskTest.java | 4 +-
.../connect/runtime/WorkerSourceTaskTest.java | 18 +-
.../storage/FileOffsetBackingStoreTest.java | 14 +-
.../storage/KafkaOffsetBackingStoreTest.java | 54 ++---
.../connect/util/ConvertingFutureCallbackTest.java | 242 +++++++++++++++++++++
13 files changed, 398 insertions(+), 104 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/state/WindowStoreIterator.java =>
connect/runtime/src/main/java/org/apache/kafka/connect/storage/CloseableOffsetStorageReader.java
(60%)
create mode 100644 connect/runtime/src/test/java/org/apache/kafka/connect/util/ConvertingFutureCallbackTest.java
|