Hi,

Many thanks for your confirm!

I have another question, if I deleted a mirrored topic on the target Kafka 
cluster, if Kafka mirror maker could mirror the same topic again from source 
cluster when I launch mirror maker next time? Thanks!






Best Regards

Johnny


-----Original Message-----
From: Manikumar [mailto:manikumar.re...@gmail.com] 
Sent: 2016年10月24日 15:03
To: users@kafka.apache.org
Subject: Re: Mirror multi-embedded consumer's configuration

I think we need to update the docs. This behavior got changed longtime ago.
we need to pass only one consumer configuration. This config will be applicable 
for all the consumer threads/instances.

On Mon, Oct 24, 2016 at 11:43 AM, ZHU Hua B <hua.b....@alcatel-lucent.com>
wrote:

> Hi,
>
>
> Because from some Kafka wiki I saw "At minimum, the mirror maker takes 
> one or more consumer configurations, a producer configuration and 
> either a whitelist or a blacklist", but the test failed, so I want to 
> know if Kafka mirror really support more consumer configurations at minimum? 
> Thanks!
>
>
>
>
> Best Regards
>
> Johnny
>
>
> -----Original Message-----
> From: Manikumar [mailto:manikumar.re...@gmail.com]
> Sent: 2016年10月24日 13:48
> To: users@kafka.apache.org
> Subject: Re: Mirror multi-embedded consumer's configuration
>
> why are you passing "consumer.config" twice?
>
> On Mon, Oct 24, 2016 at 11:07 AM, ZHU Hua B 
> <hua.b....@alcatel-lucent.com>
> wrote:
>
> > Hi,
> >
> >
> > The version of Kafka I used is 0.10.0.0. Thanks!
> >
> >
> >
> >
> >
> >
> > Best Regards
> >
> > Johnny
> >
> > -----Original Message-----
> > From: Guozhang Wang [mailto:wangg...@gmail.com]
> > Sent: 2016年10月24日 12:22
> > To: users@kafka.apache.org
> > Subject: Re: Mirror multi-embedded consumer's configuration
> >
> > Which version are you using for the MM?
> >
> > Guozhang
> >
> > On Thu, Oct 20, 2016 at 10:13 PM, ZHU Hua B 
> > <hua.b....@alcatel-lucent.com>
> > wrote:
> >
> > > Hi,
> > >
> > >
> > > Anybody could help to answer below question? Thanks!
> > >
> > >
> > >
> > >
> > >
> > > Best Regards
> > >
> > > Johnny
> > >
> > > From: ZHU Hua B
> > > Sent: 2016年10月19日 16:22
> > > To: 'users@kafka.apache.org'
> > > Subject: Mirror multi-embedded consumer's configuration
> > >
> > > Hi,
> > >
> > >
> > > I launch Kafka mirror maker with multi-embedded consumer's 
> > > configuration but failed as below, what’s the mean of “you asked 
> > > for only one”, is there an option control it? Thanks!
> > >
> > > # bin/kafka-mirror-maker.sh --consumer.config 
> > > config/consumer-1.properties --consumer.config 
> > > config/consumer-2.properties --num.streams 2 --producer.config
> > config/producer.properties --whitelist '.*'
> > > [2016-10-19 16:00:14,183] ERROR Exception when starting mirror maker.
> > > (kafka.tools.MirrorMaker$)
> > > joptsimple.MultipleArgumentsForOptionException: Found multiple 
> > > arguments for option consumer.config, but you asked for only one
> > >         at joptsimple.OptionSet.valueOf(OptionSet.java:179)
> > >         at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:235)
> > >         at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
> > > Exception in thread "main" java.lang.NullPointerException
> > >         at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:286)
> > >         at kafka.tools.MirrorMaker.main(MirrorMaker.scala)
> > >
> > >
> > >
> > >
> > >
> > >
> > > Best Regards
> > >
> > > Johnny
> > >
> > >
> >
> >
> > --
> > -- Guozhang
> >
>

Reply via email to