kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Damian Guy <damian....@gmail.com>
Subject Re: Adding topics to KafkaStreams after ingestion has been started?
Date Fri, 02 Dec 2016 14:17:14 GMT
Hi Ali,

The only way KafkaStreams will process new topics after start is if the
original stream was defined with a regular expression, i.e,
kafka.stream(Pattern.compile("foo-.*");

If any new topics are added after start that match the pattern, then they
will also be consumed.

Thanks,
Damian

On Fri, 2 Dec 2016 at 13:13 Ali Akhtar <ali.rac200@gmail.com> wrote:

> Heya,
>
> Normally, you add your topics and their callbacks to a StreamBuilder, and
> then call KafkaStreams.start() to start ingesting those topics.
>
> Is it possible to add a new topic to the StreamBuilder, and start ingesting
> that as well, after KafkaStreams.start() has been called?
>
> Thanks.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message