Hey, Cannot find a way to specify consumer ids to spout in trident. Can you suggest a way to do this. What I have tried: TridentKafkaConfig does not seem to have a constructor which takes group id, whereas Spoutconfig has the provision for id. I am using Storm 0.9.6
On Tue, Jul 26, 2016 at 6:12 PM, Stephen Powis <[email protected]> wrote: > Do you have unique consumer Ids for each spout in each topology? > > On Tue, Jul 26, 2016 at 8:40 AM, Amber Kulkarni < > [email protected]> wrote: > >> So I want multiple storm topologies to read from the same kafka topic. >> >> So suppose topic contains: A B C (data) >> >> I want both the topologies to get A,B,C >> >> But currently what is happening is messaged are getting distributed.(eg. >> topology 1 is getting A and other topology is getting B and C) >> >> How do I achieve this is trident. >> >> I am using OpaqueTridentKafkaSpout. >> >> I think what needs to be done is both topologies need to specify >> different consumer group ids. >> >> But could not find how to specify them in trident(TridentKafkaConfig) >> >> Any ideas ? >> >> Regards, >> Amber Kulkarni >> > > -- Regards, Amber Kulkarni
