[
https://issues.apache.org/jira/browse/KAFKA-13398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17434185#comment-17434185
]
Tom Bentley commented on KAFKA-13398:
-------------------------------------
[~RivenSun] the Admin client is backwards compatible, assuming the broker
version you're running supports the RPCs you need.
[https://cwiki.apache.org/confluence/display/KAFKA/Kafka+APIs] shows which APIs
are supported in which version. For example AlterPartitionsReassignments
appeared in 2.4.
If you really _do_ need to use the CLI tools then one way to avoid the
{{System.exit}} might be to run with a security manager and use {{checkExit}}
to prevent calling System.exit.
> The caller program will be shut down directly when the execution of Kafka
> script is abnormal
> --------------------------------------------------------------------------------------------
>
> Key: KAFKA-13398
> URL: https://issues.apache.org/jira/browse/KAFKA-13398
> Project: Kafka
> Issue Type: Improvement
> Components: admin
> Affects Versions: 3.0.0
> Reporter: RivenSun
> Priority: Major
>
> hello [~showuon] and [~guozhang]
> Kafka has some key functions that have not yet been integrated into
> Java-AdminClient, so I have to use some Scala classes in the Kafka Server
> `kafka.admin` package in my java program, such as:
> `ReassignPartitionsCommand`, `ConsumerGroupCommand` (reset group offsets),
> and etc., to call their `*main(args: Array[String])*` methods in order to
> achieve specific functions.
> *Problem*:
> 1. In different Kafka versions, these Scala classes may have different
> requirements for input parameters, or they may have different treatments for
> the results of command execution.
> 1) `ReassignPartitionsCommand` requires --bootstrap-server is required in
> the latest high version,
> but requires --zookeeper in the low version.
> Once the parameter verification fails, the *Exit.exit(1, Some(message))*
> method will be called, which will cause my process to shut down directly.
> 2) In Kafka 3.0.0 version, there is this code at the end in the `*main(args:
> Array[String])*` method of `ReassignPartitionsCommand`
> {code:java}
> // If the command failed, exit with a non-zero exit code.
> if (failed) {
> Exit.exit(1)
> }{code}
> This will also make my process shut down directly
> So I hope that the Kafka community will be able to print out the reason and
> stack of the corresponding exception when the parameter verification fails or
> the execution command is abnormal, and then return from the `*main(args:
> Array[String])*` method of the command, but don't call `*Exit.exit(...)*`
> method. Of course, when the script is executed on the machine, there is no
> problem with exiting directly.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
