The kafka "high level" consumer supports topic filtering for doing wildcards against topics. The storm-kafka spout uses the simple consumer which doesnt have these features (but has others needed for reliable messaging, offset management)
you could write your own high level consumer spout which could support this feature at the expense of some message reliability. Look at TopicFilter https://kafka.apache.org/08/api.html On Mon, May 12, 2014 at 4:59 PM, Amikam Snir <[email protected]> wrote: > Hi all, > > Do you know code (Spout-code), which consume from multiple topics for > example using wildcard against the topic name? > > > > The topics at my application are created dynamically. Should I just use > dedicated Kafka-Spout for each topic and somehow updated the topology at > run-time? > > > > > > Thanks in advance, > > Amikam. >
