You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rh...@apache.org on 2019/11/20 05:18:48 UTC
[kafka] branch trunk updated (41a9e2c -> da43372)
This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 41a9e2c HOTFIX: safely clear all active state in onPartitionsLost (#7691)
add da43372 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 | 27 ++-
.../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, 400 insertions(+), 105 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/SerializedInternal.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