This is an automated email from the ASF dual-hosted git repository.
rsivaram pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2e351e0 KAFKA-9152; Improve Sensor Retrieval (#7928)
add a3509c0 MINOR: MiniKdc JVM shutdown hook fix (#7946)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/kafka/common/utils/Exit.java | 26 +++++
.../org/apache/kafka/common/utils/ExitTest.java | 88 +++++++++++++++
.../test/java/org/apache/kafka/test/TestUtils.java | 14 +--
.../apache/kafka/connect/mirror/MirrorMaker.java | 2 +-
.../org/apache/kafka/connect/runtime/Connect.java | 3 +-
core/src/main/scala/kafka/Kafka.scala | 4 +-
.../main/scala/kafka/tools/ConsoleConsumer.scala | 6 +-
.../main/scala/kafka/tools/ConsoleProducer.scala | 6 +-
core/src/main/scala/kafka/tools/MirrorMaker.scala | 6 +-
.../kafka/tools/ReplicaVerificationTool.scala | 4 +-
core/src/main/scala/kafka/utils/Exit.scala | 12 +-
.../scala/kafka/security/minikdc/MiniKdc.scala | 9 +-
.../scala/kafka/security/minikdc/MiniKdcTest.scala | 46 ++++++++
core/src/test/scala/kafka/utils/ExitTest.scala | 122 +++++++++++++++++++++
.../src/test/scala/other/kafka/StressTestLog.scala | 4 +-
.../apache/kafka/streams/tests/EosTestClient.java | 33 +++---
.../apache/kafka/streams/tests/EosTestDriver.java | 4 +-
.../kafka/streams/tests/ShutdownDeadlockTest.java | 7 +-
.../kafka/streams/tests/SmokeTestClient.java | 3 +-
.../streams/tests/StaticMemberTestClient.java | 16 ++-
.../tests/StreamsBrokerDownResilienceTest.java | 6 +-
.../streams/tests/StreamsNamedRepartitionTest.java | 5 +-
.../kafka/streams/tests/StreamsOptimizedTest.java | 16 ++-
.../streams/tests/StreamsStandByReplicaTest.java | 5 +-
.../kafka/streams/tests/StreamsUpgradeTest.java | 5 +-
.../StreamsUpgradeToCooperativeRebalanceTest.java | 5 +-
.../kafka/tools/TransactionalMessageCopier.java | 5 +-
.../org/apache/kafka/tools/VerifiableConsumer.java | 2 +-
.../kafka/tools/VerifiableLog4jAppender.java | 6 +-
.../org/apache/kafka/tools/VerifiableProducer.java | 4 +-
.../java/org/apache/kafka/trogdor/agent/Agent.java | 4 +-
.../kafka/trogdor/coordinator/Coordinator.java | 4 +-
32 files changed, 374 insertions(+), 108 deletions(-)
create mode 100644
clients/src/test/java/org/apache/kafka/common/utils/ExitTest.java
create mode 100644 core/src/test/scala/kafka/security/minikdc/MiniKdcTest.scala
create mode 100644 core/src/test/scala/kafka/utils/ExitTest.scala
