[kafka] branch trunk updated (45b7a2a -> 690f72d)

[cm...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 45b7a2a  KAFKA-12339: Add retry to admin client's listOffsets (#10152)
     add 690f72d  KAFKA-12334: Add the KIP-500 metadata shell

No new revisions were added by this update.

Summary of changes:
 ...elegation-tokens.sh => kafka-metadata-shell.sh} |   2 +-
 build.gradle                                       |  43 +++
 checkstyle/import-control.xml                      |  17 ++
 checkstyle/suppressions.xml                        |   4 +
 gradle/dependencies.gradle                         |   2 +
 .../org/apache/kafka/metalog/LocalLogManager.java  |   0
 .../resources/common/metadata/IsrChangeRecord.json |   4 +-
 .../resources/common/metadata/PartitionRecord.json |   4 +-
 .../apache/kafka/metadata/MetadataParserTest.java  |   2 +-
 .../apache/kafka/metalog/LocalLogManagerTest.java  |   2 +-
 settings.gradle                                    |   1 +
 .../org/apache/kafka/shell/CatCommandHandler.java  | 120 ++++++++
 .../org/apache/kafka/shell/CdCommandHandler.java   | 117 ++++++++
 .../java/org/apache/kafka/shell/CommandUtils.java  | 148 ++++++++++
 .../main/java/org/apache/kafka/shell/Commands.java | 154 +++++++++++
 .../kafka/shell/ErroneousCommandHandler.java       |  46 ++--
 .../org/apache/kafka/shell/ExitCommandHandler.java |  88 ++++++
 .../org/apache/kafka/shell/FindCommandHandler.java | 121 +++++++++
 .../java/org/apache/kafka/shell/GlobComponent.java | 179 ++++++++++++
 .../java/org/apache/kafka/shell/GlobVisitor.java   | 148 ++++++++++
 .../org/apache/kafka/shell/HelpCommandHandler.java |  88 ++++++
 .../apache/kafka/shell/HistoryCommandHandler.java  | 108 ++++++++
 .../org/apache/kafka/shell/InteractiveShell.java   | 172 ++++++++++++
 .../org/apache/kafka/shell/LsCommandHandler.java   | 299 ++++++++++++++++++++
 .../org/apache/kafka/shell/ManCommandHandler.java  | 109 ++++++++
 .../java/org/apache/kafka/shell/MetadataNode.java  | 140 ++++++++++
 .../apache/kafka/shell/MetadataNodeManager.java    | 302 +++++++++++++++++++++
 .../java/org/apache/kafka/shell/MetadataShell.java | 174 ++++++++++++
 .../org/apache/kafka/shell/NoOpCommandHandler.java |  31 +--
 .../apache/kafka/shell/NotDirectoryException.java  |  11 +-
 .../org/apache/kafka/shell/NotFileException.java   |  13 +-
 .../org/apache/kafka/shell/PwdCommandHandler.java  |  89 ++++++
 .../org/apache/kafka/shell/SnapshotFileReader.java | 194 +++++++++++++
 .../java/org/apache/kafka/shell/CommandTest.java   |  70 +++++
 .../org/apache/kafka/shell/CommandUtilsTest.java   |  23 +-
 .../org/apache/kafka/shell/GlobComponentTest.java  |  75 +++++
 .../org/apache/kafka/shell/GlobVisitorTest.java    | 144 ++++++++++
 .../apache/kafka/shell/LsCommandHandlerTest.java   |  99 +++++++
 .../org/apache/kafka/shell/MetadataNodeTest.java   |  73 +++++
 39 files changed, 3350 insertions(+), 66 deletions(-)
 copy bin/{kafka-delegation-tokens.sh => kafka-metadata-shell.sh} (90%)
 copy metadata/src/{test => main}/java/org/apache/kafka/metalog/LocalLogManager.java (100%)
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/CatCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/CdCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/CommandUtils.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/Commands.java
 copy raft/src/main/java/org/apache/kafka/raft/LogOffsetMetadata.java => shell/src/main/java/org/apache/kafka/shell/ErroneousCommandHandler.java (53%)
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/ExitCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/FindCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/GlobComponent.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/GlobVisitor.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/HelpCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/HistoryCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/InteractiveShell.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/LsCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/ManCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/MetadataNode.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/MetadataNodeManager.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/MetadataShell.java
 copy clients/src/test/java/org/apache/kafka/common/security/oauthbearer/OAuthBearerTokenMock.java => shell/src/main/java/org/apache/kafka/shell/NoOpCommandHandler.java (64%)
 copy metadata/src/main/java/org/apache/kafka/metadata/MetadataParseException.java => shell/src/main/java/org/apache/kafka/shell/NotDirectoryException.java (78%)
 copy clients/src/main/java/org/apache/kafka/common/errors/UnknownTopicIdException.java => shell/src/main/java/org/apache/kafka/shell/NotFileException.java (79%)
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/PwdCommandHandler.java
 create mode 100644 shell/src/main/java/org/apache/kafka/shell/SnapshotFileReader.java
 create mode 100644 shell/src/test/java/org/apache/kafka/shell/CommandTest.java
 copy clients/src/test/java/org/apache/kafka/common/security/auth/KafkaPrincipalTest.java => shell/src/test/java/org/apache/kafka/shell/CommandUtilsTest.java (65%)
 create mode 100644 shell/src/test/java/org/apache/kafka/shell/GlobComponentTest.java
 create mode 100644 shell/src/test/java/org/apache/kafka/shell/GlobVisitorTest.java
 create mode 100644 shell/src/test/java/org/apache/kafka/shell/LsCommandHandlerTest.java
 create mode 100644 shell/src/test/java/org/apache/kafka/shell/MetadataNodeTest.java