Spawning multiple EventReceiverFirehose firehoses

Hello,

I’m trying to spawn multiple “receiver” firehoses (EventReceiverFirehose). The documentation says that I should use
http://:/druid/worker/v1/chat//push-events/

``

If I only have one firehose then I know that I can use the default port 8100. How do I choose which port to use when I have multiple endpoints? Shouldn’t these requests go through overlord/middlemanager or something that knows how to map eventReceiverServiceName to certain peon port?

Thanks,

Indrek

Hey Indrek,

Each task will get a unique peonHost:peonPort assigned to it, and will announce that in service discovery under the firehose name (the “eventReceiverServiceName”). You can look in service discovery to find the address and port of each firehose you want to talk to. Tranquility does something similar- spawns multiple receivers and talks to all of them- and the code it uses to do that is here:

https://github.com/druid-io/tranquility/blob/master/src/main/scala/com/metamx/tranquility/druid/DruidBeam.scala

Hope that helps.

Thank you,

Got it working.