Re: Is this the right official logo for Apache Kafka?
Thanks Neha. Menka On Sun, Jan 5, 2014 at 3:13 PM, Neha Narkhede wrote: > That's right. > On Jan 5, 2014 2:45 PM, "Menka" wrote: > > > http://upload.wikimedia.org/wikipedia/commons/f/f7/Apache_kafka.png > > > > Please help me confirm. > > > > Thanks, > > Menka > > > > > > > > -- > > Blog: http://menkag.blogspot.com > > Facebook: http://www.facebook.com/MenkasJewelry > > > > "Don't let what you cannot do interfere with what you can do" - by John > > Wooden > > > -- Blog: http://menkag.blogspot.com Facebook: http://www.facebook.com/MenkasJewelry "Don't let what you cannot do interfere with what you can do" - by John Wooden
Is this the right official logo for Apache Kafka?
http://upload.wikimedia.org/wikipedia/commons/f/f7/Apache_kafka.png Please help me confirm. Thanks, Menka -- Blog: http://menkag.blogspot.com Facebook: http://www.facebook.com/MenkasJewelry "Don't let what you cannot do interfere with what you can do" - by John Wooden
Use cases where NOT to use Kafka
Do we know particular use cases or scenarios where Kafka shouldn't be use and why? Please share. Thanks, Menka -- Blog: http://menkag.blogspot.com Facebook: http://www.facebook.com/MenkasJewelry "Don't let what you cannot do interfere with what you can do" - by John Wooden
Re: ./sbt assembly-package-dependency needed for Kafka 0.7.2?
Joe, Thanks so much. Regards, Menka On Mon, Nov 18, 2013 at 2:13 PM, Joe Stein wrote: > Nope, assembly-package-dependency was introduced for 0.8 > > /*** > Joe Stein > Founder, Principal Consultant > Big Data Open Source Security LLC > http://www.stealth.ly > Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > / > > > On Mon, Nov 18, 2013 at 4:56 PM, Menka wrote: > > > Do we need to run > > > > ./sbt assembly-package-dependency for Kafka 0.7.2? > > > > I am running into this. > > > > > > [idhuser@vmidh kafka-0.7.2-incubating-src]$ ./sbt > > assembly-package-dependency > > [info] Building project Kafka 0.7.2 against Scala 2.8.0 > > [info]using KafkaProject with sbt 0.7.5 and Scala 2.7.7 > > *[error] No action named 'assembly-package-dependency' exists.* > > [info] Execute 'help' for a list of commands or 'actions' for a list of > > available project actions and methods. > > [info] > > [info] Total time: 0 s, completed Nov 18, 2013 1:38:54 PM > > [info] > > [info] Total session time: 1 s, completed Nov 18, 2013 1:38:54 PM > > [error] Error during build. > > > > > > -- > > Blog: http://menkag.blogspot.com > > Facebook: http://www.facebook.com/MenkasJewelry > > > > "Don't let what you cannot do interfere with what you can do" - by John > > Wooden > > > -- Blog: http://menkag.blogspot.com Facebook: http://www.facebook.com/MenkasJewelry "Don't let what you cannot do interfere with what you can do" - by John Wooden
./sbt assembly-package-dependency needed for Kafka 0.7.2?
Do we need to run ./sbt assembly-package-dependency for Kafka 0.7.2? I am running into this. [idhuser@vmidh kafka-0.7.2-incubating-src]$ ./sbt assembly-package-dependency [info] Building project Kafka 0.7.2 against Scala 2.8.0 [info]using KafkaProject with sbt 0.7.5 and Scala 2.7.7 *[error] No action named 'assembly-package-dependency' exists.* [info] Execute 'help' for a list of commands or 'actions' for a list of available project actions and methods. [info] [info] Total time: 0 s, completed Nov 18, 2013 1:38:54 PM [info] [info] Total session time: 1 s, completed Nov 18, 2013 1:38:54 PM [error] Error during build. -- Blog: http://menkag.blogspot.com Facebook: http://www.facebook.com/MenkasJewelry "Don't let what you cannot do interfere with what you can do" - by John Wooden
Consumer example not working for 0.8 beta
I am a newbie for Kafka and trying to execute the samples for 0.8 beta
release from
https://github.com/apache/kafka/tree/0.8.0-beta1candidate1/examples/src/main/java/kafka/examples<https://github.com/apache/kafka/tree/0.8.0-beta1-candidate1/examples/src/main/java/kafka/examples>
I tried KafkaConsumerProducerDemo and wanted to print what Consumer is
consuming but its not doing anything (Consumer.java).
public void run() {
System.out.println(name + "(consumer)--> in run");
Map topicCountMap = new HashMap();
topicCountMap.put(topic, new Integer(1));
Map>> consumerMap =
consumer.createMessageStreams(topicCountMap);
KafkaStream stream = consumerMap.get(topic).get(0);
ConsumerIterator it = stream.iterator();
while(it.hasNext()) {
//
System.out.println(ExampleUtils.getMessage(it.next().message()));
System.out.println(name + "(consumer)--> " + new
String(it.next().message()));
}
Any suggestion on what I might be doing wrong here?
Thanks,
Menka
--
Blog: http://menkag.blogspot.com
"Don't let what you cannot do interfere with what you can do" - by John
Wooden
