KrishnaRao Veeramachaneni

Results 12 comments of KrishnaRao Veeramachaneni

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

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

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...

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 : Yes. our usecase is - Pull multiple kafka messages from Confluent Cluster - Call Parallel API calls to API - Persist the data

Please find the code ``` VertxParallelStreamProcessor parallelConsumer; public void run(){ Consumer kafakaConsumer = getKafkaConsumer(); var options = parallelConsumerOptions.builder().ordering(KEY).consumer(kafakaConsumer).maxConcurrency(10).build(); this.parallelConsumer = VertxParallelStreamProcessor.createEosStreamProcessor(options); parallelConsumer.subscrribe(of("test-topic")); parallelConsumer.vertxHttpWebClient((wc,rec) -> wc.postAbs("https://www.google.com").putHeaders("Content-Type","application/json").sendJson("{}").onSuccess(response -> { log.info("Response""+response.bodyAsString())} .onFailure(err ->...

`2021-11-25 11:47:44.084 [vert.x-eventloop-thread-1] INFO c.j.c.r.u.a.c.ParallelConsumer - Failure --Failed to create SSL connection 2021-11-25 11:47:44.084 [vert.x-eventloop-thread-1] ERROR i.c.p.v.VertxParallelEoSStreamProcessor - Vert.x Vertical fail: Failed to create SSL connection`

our port is 8443 not 443. vert.x function validating the SSL Certificate and not able to see the CIPHER. May be we can set - HttpClinetOptions.setTrustAll(true); Not sure ..how to...

I'm referring this [example](https://vertx.io/docs/vertx-web-client/java/#_using_https)