/assign

Hello, I have a few questions in the process of implementing this issue, and I hope to get answers. Regarding your optimization requirement: "By adding the -catchup-topic-prefix prefix, the script can reuse the existing topic", I found that the perfcommend class is the actual test tool. Do I need to modify the code of this class to verify the "-catchup-topic-prefix" prefix parameter, or can I meet the requirement by simply modifying the logic of automq-perf-test.sh?

Hello, I have a few questions in the process of implementing this issue, and I hope to get answers. Regarding your optimization requirement: "By adding the -catchup-topic-prefix prefix, the script can reuse the existing topic", I found that the perfcommend class is the actual test tool. Do I need to modify the code of this class to verify the "-catchup-topic-prefix" prefix parameter, or can I meet the requirement by simply modifying the logic of automq-perf-test.sh?

Hello, @xiayu1118, the automq-perf-test.sh script primarily serves as an entry point that ultimately executes the org.apache.kafka.tools.automq.PerfCommand#main method. To implement this feature, you will need to modify the relevant Java code rather than just the shell script logic.

Specifically, you should add the new command-line option (e.g., --catchup-topic-prefix) in the org.apache.kafka.tools.automq.perf.PerfConfig class to parse and validate the parameter. Then, implement the corresponding logic in the org.apache.kafka.tools.automq.PerfCommand and org.apache.kafka.tools.automq.perf.ConsumerService class to handle topic reuse based on the prefix.

Feel free to reach out if you need further clarification or assistance during implementation!

Hello, I have a few questions in the process of implementing this issue, and I hope to get answers. Regarding your optimization requirement: "By adding the -catchup-topic-prefix prefix, the script can reuse the existing topic", I found that the perfcommend class is the actual test tool. Do I need to modify the code of this class to verify the "-catchup-topic-prefix" prefix parameter, or can I meet the requirement by simply modifying the logic of automq-perf-test.sh?

Hello, @xiayu1118, the automq-perf-test.sh script primarily serves as an entry point that ultimately executes the org.apache.kafka.tools.automq.PerfCommand#main method. To implement this feature, you will need to modify the relevant Java code rather than just the shell script logic.

Specifically, you should add the new command-line option (e.g., --catchup-topic-prefix) in the org.apache.kafka.tools.automq.perf.PerfConfig class to parse and validate the parameter. Then, implement the corresponding logic in the org.apache.kafka.tools.automq.PerfCommand and org.apache.kafka.tools.automq.perf.ConsumerService class to handle topic reuse based on the prefix.

Feel free to reach out if you need further clarification or assistance during implementation!

Got it！

Hello, I encountered a problem while trying to test my new bash script that supports reusing existing themes through prefixes: Does autoMQ currently support source code deployment? I encountered a lot of problems while compiling and packaging autoMQ, and I was wondering if I had gone in the wrong direction; Or is there a more convenient way to run test scripts?

It's okay, I solved it here.

/assign