Hey Drew,

You can easily use a WhiteList passing as parameter your regex pattern.

E.g:

Whitelist filter = new Whitelist(“topic_\\d+”);
consumer.createMessageStreamsByFilter(filter, 1);


> On Aug 19, 2016, at 2:46 AM, Drew Kutcharian <d...@venarc.com> wrote:
> 
> Hi,
> 
> Can I create a Kafka Streams app that consumes from a set of topics prefixed 
> by some prefix? The way it’s possible using createMessageStreamsByFilter? If 
> so, how?
> 
> Best,
> 
> Drew

Reply via email to