You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by vv...@apache.org on 2020/09/03 19:17:57 UTC
[kafka] branch trunk updated (c04000c -> 1e31354)
This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from c04000c KAFKA-9924: Add remaining property-based RocksDB metrics as described in KIP-607 (#9232)
add 1e31354 KAFKA-10355: Throw error when source topic was deleted (#9191)
No new revisions were added by this update.
Summary of changes:
.../errors/MissingSourceTopicException.java | 9 +-
.../internals/StreamsRebalanceListener.java | 8 +-
...HandlingSourceTopicDeletionIntegrationTest.java | 114 +++++++++++++++++++++
.../internals/StreamsRebalanceListenerTest.java | 74 +++++++++++++
4 files changed, 198 insertions(+), 7 deletions(-)
copy clients/src/main/java/org/apache/kafka/common/errors/GroupSubscribedToTopicException.java => streams/src/main/java/org/apache/kafka/streams/errors/MissingSourceTopicException.java (78%)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/HandlingSourceTopicDeletionIntegrationTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListenerTest.java