kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Boris Lublinsky <boris.lublin...@lightbend.com>
Subject Re: Kafka Streams question
Date Mon, 13 Nov 2017 14:49:17 GMT
This seems like a very limiting implementation


Boris Lublinsky
FDP Architect
boris.lublinsky@lightbend.com
https://www.lightbend.com/

> On Nov 13, 2017, at 4:21 AM, Damian Guy <damian.guy@gmail.com> wrote:
> 
> Hi,
> 
> The configurations apply to all streams consumed within the same streams
> application. There is no way of overriding it per input stream.
> 
> Thanks,
> Damian
> 
> On Mon, 13 Nov 2017 at 04:49 Boris Lublinsky <boris.lublinsky@lightbend.com>
> wrote:
> 
>> I am writing Kafka Streams implementation (1.0.0), for which I have 2
>> input streams.
>> Is it possible to have different subscriber IDs for these 2 streams.
>> I see only one place where subscriber’s ID can be specified:
>> 
>> streamsConfiguration.put(StreamsConfig.CLIENT_ID_CONFIG,
>> ApplicationKafkaParameters.DATA_GROUP);
>> And it does not seem like either Topology or DSL APIs allow to overwrite
>> it during Stream creation.
>> 
>> Thanks for the help
>> 
>> Boris Lublinsky
>> FDP Architect
>> boris.lublinsky@lightbend.com
>> https://www.lightbend.com/
>> 
>> 


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