Hi Michael, Thank you very much for the prompt response, really appreciate it!
>From https://github.com/confluentinc/examples/blob/3.2.x/kafka- streams/src/main/java/io/confluent/examples/streams/Wor dCountLambdaExample.java#L55-L62 and https://github.com/confluentinc/examples/tree/3.2.x/kafka-streams#packaging-and-running I missed the fact that the jar should be run in a separate container. Best regards, Mina On Tue, Mar 21, 2017 at 4:34 PM, Michael Noll <mich...@confluent.io> wrote: > Typically you'd containerize your app and then launch e.g. 10 containers if > you need to run 10 instances of your app. > > Also, what do you mean by "in a cluster of Kafka containers" and "in the > cluster of Kafkas"? > > On Tue, Mar 21, 2017 at 9:08 PM, Mina Aslani <aslanim...@gmail.com> wrote: > > > Hi, > > > > I am trying to understand how I can use a kafka stream app(jar file) in a > > cluster of kafka containers. > > > > Kafka does not have master/slave concept (unlike spark), how I should run > > my app in the cluster of kafkas (e.g. on one or multiple > docker-machine/s)? > > > > I use below command line when having one VM/node with one kafka container > > https://github.com/confluentinc/examples/blob/3. > > 2.x/kafka-streams/src/main/ > > java/io/confluent/examples/streams/WordCountLambdaExample.java#L55-L62 > > > > Best regards, > > Mina > > >
