vertxHttpReqInfo only supports GET (Unable to call HTTP POST or PUT etc)

[OpenSourceTycoon]

Hi There,

I'm able to consume the Kafka Message, but while i trigger the async API call using

Stream<JStreamVertxParallelEoSStreamProcessor.VertxCPResult<String,String>> resultStream = parallelConsumer.vertxHttpReqInfoStream(record -> {
String apiReq = "{id:1}";
// Need to call POST VERB
Map<String, String> params = UniMaps.of("recordKey", "12345", "payload", apiReq );
return new VertxParallelEoSStreamProcessor.RequestInfo("abc.workin.net", 8443, "/api/v1/limit", params);

This is internally calling GET VERB ( not POST VERB ). Can someone help me understand the POST call ?

[OpenSourceTycoon]

@astubbs : Can you help me on this ?

[astubbs]

Hi @OpenSourceTycoon ! Welcome to the project, and thanks for submitting this issue! We appreciate your involvement.

You have indeed uncovered some missing features :) The vertxReqInfo method currently only supports GET requests, as seen on this line.

It shouldn't be hard to add support for the other methods.

However, in the mean time, as a workaround, you can simply use the other methods - either vertxHttpRequest, or vertxWebClient which let you construct any sort of request you want that VertX's WebClient interface supports.

Let me know if that solves your problem.

[OpenSourceTycoon]

@astubbs : can you provide examples for vertxHttpRequest, or vertxWebClient ?

[astubbs]

Sure!

    void webClientExample(VertxParallelStreamProcessor<String, String> parallelConsumer) {
        parallelConsumer.vertxHttpRequest((wc, rec) -> wc.post("some uri"),
                httpResponseFuture -> {
                },
                httpResponseAsyncResult -> {
                }
        );
    }

    void httpRequestExample(VertxParallelStreamProcessor<String, String> parallelConsumer) {
        parallelConsumer.vertxHttpWebClient((wc, rec) -> wc.post("some uri").send(),
                httpResponseFuture -> {
                }
        );
    }

[astubbs]

I've also added a PR to make the API simpler for your use- assuming you aren't interested in using the callback hooks?

https://github.com/confluentinc/parallel-consumer/pull/181/files

[OpenSourceTycoon]

@astubbs PR available for Merge Process. Can you provide the release jars path after merge process. ? Thanks in advance.

[astubbs]

The PR doesn't need to be merged to solve your problem. Just use the "no op" call back functions like in the example above. E.g. :httpResponseFuture -> {}

[OpenSourceTycoon]

Thanks @astubbs. I'm using below code

parallelConsumer.vertxHttpWebClient((wc, rec) -> wc.postAbs("some uri").send(), httpResponseFuture -> { } );

However, i see "Failed to create SSL connection" - Vert.x Vertical Fail : Failed to create SSL connection" issue

[OpenSourceTycoon]

There is a method on the HttpClientOptions, we need to call that method with false. We can use options class in to my code.

[astubbs]

Are you still having an issue? Can you provide. Full failing example perhaps with a broken test?