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
|