Kafka Mirroring Issue: Leader Not Available Exception

2016-03-19 Thread Anshul Bhatnagar
I am trying to mirror a three node kafka cluster to a single node cluster. When I starts the mirror maker I got the exception LeaderNotAvailable, but at the same time topics are created and messages are commited. Please help me out. Best Regards Anshul Bhatnagar

Re: kafka mirroring ...!

2015-03-09 Thread sunil kalva
have multiple partitions for that topic in source and destination clusters. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka mirroring tool after producing data in source cluster

Re: kafka mirroring ...!

2015-03-09 Thread Jiangjie Qin
partitions for that topic in source and destination clusters. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka mirroring tool after producing data in source cluster

Re: kafka mirroring ...!

2015-03-09 Thread tao xiao
and destination clusters. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka mirroring tool after producing data in source cluster, and this is not copied to destination cluster. If i produce data

Re: kafka mirroring ...!

2015-03-08 Thread Alex Melville
. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka mirroring tool after producing data in source cluster, and this is not copied to destination cluster. If i produce data after running tool those data are copied to destination

Re: kafka mirroring ...!

2015-03-08 Thread tao xiao
: And i also observed ,all the data is moving to one partition in destination cluster though i have multiple partitions for that topic in source and destination clusters. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka

Re: kafka mirroring ...!

2015-03-07 Thread Jiangjie Qin
for that topic in source and destination clusters. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka mirroring tool after producing data in source cluster, and this is not copied to destination cluster. If i produce data after running tool

Re: kafka mirroring ...!

2015-03-07 Thread sunil kalva
And i also observed ,all the data is moving to one partition in destination cluster though i have multiple partitions for that topic in source and destination clusters. SunilKalva On Sat, Mar 7, 2015 at 9:54 PM, sunil kalva sambarc...@gmail.com wrote: I ran kafka mirroring tool after producing

kafka mirroring ...!

2015-03-07 Thread sunil kalva
I ran kafka mirroring tool after producing data in source cluster, and this is not copied to destination cluster. If i produce data after running tool those data are copied to destination cluster. Am i missing something ? -- SunilKalva

Re: Kafka Mirroring Issue

2014-09-04 Thread Ashutosh Prasad Panigrahi
. Datacenter1 :3 kafka nodes/3 zookeeper nodes 2. Datacenter 2 : 3 kafka nodes/3 zookeeper nodes All the kafka nodes are configured with auto.create.topics.enable=true and the default partition is 2 . I start the kafka mirroring tool with the following

Re: Kafka Mirroring Issue

2014-08-25 Thread François Langelier
like this 1. Datacenter1 :3 kafka nodes/3 zookeeper nodes 2. Datacenter 2 : 3 kafka nodes/3 zookeeper nodes All the kafka nodes are configured with auto.create.topics.enable=true and the default partition is 2 . I start the kafka mirroring tool with the following

Re: Kafka Mirroring Issue

2014-08-25 Thread François Langelier
kafka nodes/3 zookeeper nodes All the kafka nodes are configured with auto.create.topics.enable=true and the default partition is 2 . I start the kafka mirroring tool with the following command bin/kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config

Kafka Mirroring Issue

2014-08-21 Thread Ashutosh Prasad Panigrahi
zookeeper nodes 2. Datacenter 2 : 3 kafka nodes/3 zookeeper nodes All the kafka nodes are configured with auto.create.topics.enable=true and the default partition is 2 . I start the kafka mirroring tool with the following command bin/kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config

Re: Kafka Mirroring Issue

2014-08-21 Thread Guozhang Wang
nodes 2. Datacenter 2 : 3 kafka nodes/3 zookeeper nodes All the kafka nodes are configured with auto.create.topics.enable=true and the default partition is 2 . I start the kafka mirroring tool with the following command bin/kafka-run-class.sh kafka.tools.MirrorMaker --consumer.config

Re: Kafka Mirroring setup

2013-08-22 Thread Maxime Brugidou
We sort of have the same situation where our analytics DC is one of the main producer DC too. If you use Kafka only for analytics it is fine to produce directly to the analytics cluster from that DC and mirror the rest. However we also want to be able to run things locally that will consume local

Kafka Mirroring setup

2013-08-20 Thread Andrew Otto
Hi all! Wikimedia is investigating how best to set up Broker clusters in multiple data centers. Our main analytics Broker cluster is currently in our main datacenter. It is possible for all of the main DC's frontend producers to produce directly to our analytics cluster, but we're not sure

Re: Kafka Mirroring setup

2013-08-20 Thread Jay Kreps
We do something like A (though I'm not sure I understand B): http://kafka.apache.org/documentation.html#datacenters Essentially what we wanted was that each datacenter stood alone so that we would not lose data if the datacenters became disconnected. Network partitions within our data centers are

Re: Kafka Mirroring setup

2013-08-20 Thread Andrew Otto
In our case, our aggregator/analytics cluster is in our main datacenter, so there's no risk of the main producers becoming disconnected from it. It seems nicer to have a dedicated aggregator cluster, that only only gets its data via MirrorMaker (Option A), but in our case this isn't necessary.

Kafka mirroring fault tolerance

2013-03-22 Thread Riju Kallivalappil
Hi, I've a question about fault tolerance of Kafka mirror maker (0.7.1) Let's say that I've a mirroring setup with topics in broker B1 mirrored to broker B2. On B2, I've Kafka mirror maker and Kafka broker process running. Now, following is what I noticed when the Kafka broker process on B2 is

Re: Kafka mirroring fault tolerance

2013-03-22 Thread Jun Rao
Yes, this is true if you have only 1 broker in the target cluster. If you set up multiple brokers in the target cluster, mirror maker will send messages to available brokers. Thanks, Jun On Fri, Mar 22, 2013 at 12:02 PM, Riju Kallivalappil riju.kallivalap...@corp.247customer.com wrote: Hi,