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 11f0ea3 KAFKA-12432: AdminClient should time out nodes that are never
ready (#10281)
add 9bf5c57 KAFKA-12435: Fix javadoc errors (#10392)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 -
.../remote/storage/RemoteLogMetadataManager.java | 2 +-
.../log/remote/storage/RemoteLogSegmentState.java | 2 +-
.../processor/internals/StreamsProducer.java | 2 +-
.../apache/kafka/streams/TopologyTestDriver.java | 174 ++++++++++++++++++++-
.../streams/internals/KeyValueStoreFacade.java | 99 ------------
.../kafka/streams/internals/WindowStoreFacade.java | 109 -------------
.../processor/internals/TestDriverProducer.java | 44 ------
.../{internals => }/KeyValueStoreFacadeTest.java | 4 +-
.../{internals => }/WindowStoreFacadeTest.java | 3 +-
10 files changed, 178 insertions(+), 262 deletions(-)
delete mode 100644
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/KeyValueStoreFacade.java
delete mode 100644
streams/test-utils/src/main/java/org/apache/kafka/streams/internals/WindowStoreFacade.java
delete mode 100644
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/internals/TestDriverProducer.java
rename streams/test-utils/src/test/java/org/apache/kafka/streams/{internals =>
}/KeyValueStoreFacadeTest.java (98%)
rename streams/test-utils/src/test/java/org/apache/kafka/streams/{internals =>
}/WindowStoreFacadeTest.java (98%)
