Re: refactoring ZK so it is plugable, would this make sense?

You can run with a single node zookeeper cluster also. See http://zookeeper.apache.org/doc/r3.3.4/zookeeperStarted.html#sc_InstallingSingleMode Cheers, Erik. Op 9 okt. 2014, om 22:52 heeft S Ahmed het volgende geschreven: > I want kafka features (w/o the redundancy) but don't want to have

How to produce and consume events in 2 DCs?

mirroring to a topic with another name. Is there another tool we could use? Or, is there another approach for producing and consuming from 2 DCs? Kind regards, Erik. — Erik van Oosten http://www.day-to-day-stuff.blogspot.nl/

Re: How to produce and consume events in 2 DCs?

pies data from both the DC's local clusters into the aggregate > clusters. So if you want access to a topic with data from both DC's, you > subscribe to the aggregate cluster. > > Thanks, > Neha > > On Mon, Oct 20, 2014 at 7:07 AM, Erik van oosten < >

Re: How to produce and consume events in 2 DCs?

Erik. Steven Wu schreef op 22-10-14 om 01:48: I think it doesn't have to be two more clusters. can be just two more topics. MirrorMaker can copy from source topics in both regions into one aggregate topic. On Tue, Oct 21, 2014 at 1:54 AM, Erik van oosten < e.vanoos...@grons.nl.i

Re: MBeans, dashes, underscores, and KAFKA-1481

? So, instead of "kafka.server":type="BrokerTopicMetrics",name="topic-1-BytesInPerSec" we will have kafka.server:type=BrokerTopicMetrics,name=BytesInPerSec,topic=topic-1 Thanks, Jun -- Erik van Oosten http://www.day-to-day-stuff.blogspot.com/

Re: trouble building 0.8

rror] Use 'last' for the full log. So here's my /Users/reefedjib/.sbt/plugins: resolvers += Classpaths.typesafeResolver addSbtPlugin("com.typesafe.sbteclipse" % "sbteclipse-plugin" % "2.2.0") and I just clone 0.8, no changes. Is there anywhere else I need to look for sbt plugin configs, outside akka? thanks, rob -- Erik van Oosten http://www.day-to-day-stuff.blogspot.com/

How to get async commit callbacks in the rebalance listener?

the question: What method should I invoke (from the onPartitionsRevoked callback), to make the Kafka client invoke the callback of earlier async commits? Some context: I am working on zio-kafka; a completely async library that provides a concurrent streaming layer on top of the Java client

Re: running on scala 2.11

efFoundError: scala/collection/GenTraversableOnce$class* Thanks Laszlo -- -- Guozhang -- Erik van Oosten http://www.day-to-day-stuff.blogspot.com/