Hi,

I'm reccently saw Flux in storm 1.0.2 and I wanted to convert my topology.

I've just an issue with a CustomGrouping Object.

Previous, I instanciate it like this :

builder.setBolt("fetcher", new FetcherBolt(), numWorkers)
        .customGrouping("spout", new FetcherCustomGrouping(getConf()))

the getConf() method return the map with the storm conf, In fact, the
customGrouping use the conf to know a redis connection informations.
I don't know how to pass this with flux yaml configuration.

Someone as any idea ?

Thank you

Reply via email to