ppawel commented on PR #37164:
URL: https://github.com/apache/beam/pull/37164#issuecomment-3753655988
> Paweł, there is new commit with ACK using SEMP api (delete message from
queue). API call happens after reshuffle so it's guaranteed that message was
checkpointed.
>
> Change was tested with solace pubsub standard container.
OK, I will try to test it but we had problems in the past with accessing
SEMP API in our central broker (due to security restrictions IIRC), so if this
is the target solution, we will need to rethink a bit (on our side)..
In integration tests I think there is one issue coming up regarding queues
with slashes - should probably be URL-encoded as the ACK call now gets error
400 from Solace:
```
{"meta":{"error":{"code":6,"description":"Could not find match for msg
1","status":"NOT_FOUND"},"request":{"method":"PUT","uri":"http://localhost:8080/SEMP/v2/action/msgVpns/default/queues/ocsssc/q/queue/with/slashes/msgs/1/delete"},"responseCode":400}}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
