I can see the events hitting my collector, but it looks like there is an error. I have not been able to find a way to solve this. I am not sure were to control the HTTP method, if at all possible.
Here is the error:
[WARN] [02/12/2021 16:07:21.695] [scala-stream-collector-akka.actor.default-dispatcher-26] [akka.actor.ActorSystemImpl(scala-stream-collector)] Illegal request, responding with status '400 Bad Request': Unsupported HTTP method: The HTTP method started with 0x16 rather than any known HTTP method. Perhaps this was an HTTPS request sent to an HTTP endpoint? [DEBUG] [02/12/2021 16:07:21.697] [scala-stream-collector-akka.actor.default-dispatcher-26] [StreamUtils$DelayCancellationStage$$anon$11(akka://scala-stream-collector)] Delaying cancellation for 1 minute