-
Notifications
You must be signed in to change notification settings - Fork 3.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[pulsar-perf] Support WebSocket Producer for V2 Topics #8535
[pulsar-perf] Support WebSocket Producer for V2 Topics #8535
Conversation
@@ -166,7 +168,9 @@ public void runPerformanceTest(long messages, long limit, int numOfTopic, int si | |||
String topicName, String authPluginClassName, String authParams) throws InterruptedException, FileNotFoundException { | |||
ExecutorService executor = Executors.newCachedThreadPool(new DefaultThreadFactory("pulsar-perf-producer-exec")); | |||
HashMap<String, Tuple> producersMap = new HashMap<>(); | |||
String produceBaseEndPoint = baseUrl + "ws/producer" + topicName; | |||
String replacedTopicName = topicName.replace("://", "/"); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think there has a method getRestPath
in the TopicName do the same thing with you.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thank you for the advice.
I fixed it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
The CI issue already fixed and merged into the master branch. Please rebase your code to make the CI pass.
…_producer_for_v2_topic
/pulsarbot run-failure-checks |
2 similar comments
/pulsarbot run-failure-checks |
/pulsarbot run-failure-checks |
### Motivation - Not support v2 topics. - Not working because `/` is missing between `"ws/producer" and topicName` https://github.com/apache/pulsar/blob/1c7b12d379cf36183d60919dcaff75e4d6cf63f2/pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java#L169 ### Modifications - Fix that if use V2 topics, use "ws/v2/producer/".
/pulsarbot cherry-pick to branch-2.6 |
### Motivation - Not support v2 topics. - Not working because `/` is missing between `"ws/producer" and topicName` https://github.com/apache/pulsar/blob/1c7b12d379cf36183d60919dcaff75e4d6cf63f2/pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java#L169 ### Modifications - Fix that if use V2 topics, use "ws/v2/producer/". (cherry picked from commit 67f544c)
### Motivation - Not support v2 topics. - Not working because `/` is missing between `"ws/producer" and topicName` https://github.com/apache/pulsar/blob/1c7b12d379cf36183d60919dcaff75e4d6cf63f2/pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java#L169 ### Modifications - Fix that if use V2 topics, use "ws/v2/producer/". (cherry picked from commit 67f544c) (cherry picked from commit 81d5caa)
Motivation
/
is missing between"ws/producer" and topicName
pulsar/pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java
Line 169 in 1c7b12d
Modifications