confluentinc / confluentinc/parallel-consumer

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

Open
#180 20 comments 0 reactions 0 assignees View on GitHub
enhancement help wanted low
Dominant language
Java
Stars
299
Forks
172
PR merge metrics
No merged PRs in 30d

Description

Hi There,

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

```
Stream> resultStream = parallelConsumer.vertxHttpReqInfoStream(record -> {
String apiReq = "{id:1}";
// Need to call POST VERB
Map 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 ?

Contributor guide

No contributing guide indexed for this repository

Research direction

Start at the vertxHttpReqInfoStream entry point and the RequestInfo construction shown in the issue, then trace how its params are turned into an HTTP request. Check the issue discussion for the intended POST behavior and any existing HTTP request tests. Done means the API can issue the requested POST, with the expected request data, without regressing the current GET path.

Written by the indexing model from the issue text.

Assessment

Tech stack
java, kafka
Domain
api, backend
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Quiet
Clarity
Mostly clear
Newbie friendliness
38/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.