Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
clear query|facets|time Search criteria: .   Results from 11 to 20 from 7032 (0.171s).
Loading phrases to help you
refine your search...
Fwd: kafka partitions api - Kafka - [mail # user]
...HelloAfter retrieving a kafka stream or kafka message how to get thecorresponding partition number to which it belongs ? I am using kafkaversion 0.8.1.More specifically kafka.consumer.KafkaS...
   Author: Gaurav Agarwal, 2015-02-26, 19:13
[KAFKA-1755] Improve error handling in log cleaner - Kafka - [issue]
...The log cleaner is a critical process when using compacted topics.However, if there is any error in any topic (notably if a key is missing) then the cleaner exits and all other compacted top...
http://issues.apache.org/jira/browse/KAFKA-1755    Author: Joel Koshy, 2015-02-26, 18:54
[expand - 2 more] - Re: Batching with new Producer API - Kafka - [mail # user]
...Oh, that makes a lot more sense!  I assumed that the batch size was interms of number of messages, not the number of bytes because it was sosmall.  What would be a reasonable value...
   Author: Akshat Aranya, 2015-02-26, 18:50
[expand - 1 more] - Re: File as message's content - Kafka - [mail # user]
...Kafka can accept any type of data, you just pass a byte[] to the producerand get a byte[] back from the consumer. How you interpret it is entirelyup to your application.But it does have limi...
   Author: Ewen Cheslack-Postava, 2015-02-26, 18:08
[expand - 4 more] - Re: non-blocking sends when cluster is down - Kafka - [mail # user]
...Thanks Steven. We changed the code to ensure that the producer is onlycreated one and reused so that the metadata fetch doesn't happen everysend() call.On 26 February 2015 at 12:44, Steven W...
   Author: Gary Ogden, 2015-02-26, 17:37
[expand - 4 more] - Re: "at least once" consumer recommendations for a load of 5 K messages/second - Kafka - [mail # user]
...A note on throughput with an at-least-once guarantee using the high-levelconsumer: The core unit of concurrency in kafka is the partition, because you can'thave more clients than partitions....
   Author: Jeff Wartes, 2015-02-26, 17:05
Kafka Offset Request for particular zookeeper chroot. - Kafka - [mail # user]
...Hi,For sending Offset Request with Kafka 0.8.2, I used this example :FindingStarting Offset for ReadsIt works great on my test environment where a kafka broker uses the defaultzookeeper chro...
   Author: François Méthot, 2015-02-26, 16:37
[KAFKA-1792] change behavior of --generate to produce assignment config with fair replica distribution and minimal number of reassignments - Kafka - [issue]
...Current implementation produces fair replica distribution between specified list of brokers. Unfortunately, it doesn't takeinto account current replica assignment.So if we have, for instance...
http://issues.apache.org/jira/browse/KAFKA-1792    Author: Dmitry Pekar, 2015-02-26, 15:02
[expand - 1 more] - Re: can we send pdf, image files in kafka queue - Kafka - [mail # user]
...It can be done, sure. We built a prototype a while backhttps://github.com/stealthly/f2k though I can't say I have bumped into ause case where the tradeoffs worked to do it. Chunking the file...
   Author: Joe Stein, 2015-02-26, 14:21
Kafka performance test failed - Kafka - [mail # user]
...Hi,I am using kafka_2.9.2-0.8.1.1Intended to run performance test using run-simulator.sh file.I started zookeeper and kafka server and finally run the below command/run-simulator.sh -kafkaSe...
   Author: Bhuvana Baskar, 2015-02-26, 12:13
Sort:
project
HBase (19230)
Hive (18441)
Hadoop (16965)
Spark (15304)
Ambari (12186)
Accumulo (11906)
MapReduce (10981)
Cassandra (8698)
Tez (8341)
HDFS (8155)
Pig (7992)
Kafka (6984)
Bigtop (5768)
Storm (4381)
YARN (4236)
Drill (4175)
Flume (3931)
Blur (3723)
Impala (3470)
Zookeeper (3454)
Avro (3424)
Sqoop (3381)
Phoenix (2830)
Mesos (2766)
Tajo (2700)
type
mail # user (2810)
mail # dev (2156)
issue (1954)
web site (111)
wiki (1)
date
last 7 days (157)
last 30 days (459)
last 90 days (853)
last 6 months (1408)
last 9 months (6921)
author
Jun Rao (1058)
Neha Narkhede (568)
Neha Narkhede (412)
Jay Kreps (351)
Guozhang Wang (285)
Jun Rao (276)
Joe Stein (252)
Joel Koshy (195)
John Fung (95)
Joe Stein (94)
Jay Kreps (89)
Guozhang Wang (88)
Jason Rosenberg (77)
Gwen Shapira (64)
Sriram Subramanian (60)
None (60)
Chris Burroughs (58)
David Arthur (58)
Swapnil Ghike (58)
Swapnil Ghike (51)
John Fung (39)
Joel Koshy (38)
Otis Gospodnetic (29)
Bhavesh Mistry (27)
Sriram Subramanian (27)
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB