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 151 to 160 from 7119 (0.198s).
Loading phrases to help you
refine your search...
[expand - 6 more] - Re: kafka partitions api - Kafka - [mail # user]
...Alex,You can get partition from MessageAndMetadata as partition is exported viaconstructor parameterOn Fri, Feb 27, 2015 at 2:12 PM, Alex Melville  wrote:Regards,Tao ...
   Author: tao xiao, 2015-02-27, 06:37
[expand - 5 more] - Re: "at least once" consumer recommendations for a load of 5 K messages/second - Kafka - [mail # user]
...Thanks a bunch for the detailed response and tips!! Looks like I have acouple of knobs one of which should work, I will be doing some runs tofigure out what works best for my use case.Thanks...
   Author: Anand Somani, 2015-02-27, 02:32
how to remove consumer group.id with storage=kafka - Kafka - [mail # user]
...All,There exists code in the sample console consumer that ships with kafka,that will remove consumer group id's from zookeeper, for the case whereit's just a short-lived session using an aut...
   Author: Jason Rosenberg, 2015-02-27, 00:06
[KAFKA-1881] transient unit test failure in testDeleteTopicWithCleaner due to OOME - Kafka - [issue]
...kafka.admin.DeleteTopicTest > testDeleteTopicWithCleaner FAILED    java.lang.OutOfMemoryError: Java heap space        at java.nio.HeapByteBuffer.&l...
http://issues.apache.org/jira/browse/KAFKA-1881    Author: Jun Rao, 2015-02-26, 23:04
[KAFKA-1684] Implement TLS/SSL authentication - Kafka - [issue]
...Add an SSL port to the configuration and advertise this as part of the metadata request.If the SSL port is configured the socket server will need to add a second Acceptor thread to listen on...
http://issues.apache.org/jira/browse/KAFKA-1684    Author: Jay Kreps, 2015-02-26, 19:39
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
Sort:
project
HBase (19312)
Hive (18547)
Hadoop (17060)
Spark (15640)
Ambari (12346)
Accumulo (11932)
MapReduce (10979)
Cassandra (8793)
Tez (8365)
HDFS (8208)
Pig (8013)
Kafka (7070)
Bigtop (5801)
Storm (4422)
Drill (4388)
YARN (4269)
Flume (3947)
Blur (3727)
Impala (3521)
Zookeeper (3457)
Sqoop (3448)
Avro (3437)
Phoenix (2878)
Mesos (2823)
Tajo (2723)
type
mail # user (2865)
mail # dev (2166)
issue (1976)
web site (111)
wiki (1)
date
last 7 days (153)
last 30 days (501)
last 90 days (911)
last 6 months (1416)
last 9 months (7008)
author
Jun Rao (1058)
Neha Narkhede (571)
Neha Narkhede (412)
Jay Kreps (353)
Guozhang Wang (288)
Jun Rao (276)
Joe Stein (250)
Joel Koshy (197)
John Fung (95)
Joe Stein (94)
Jay Kreps (89)
Guozhang Wang (88)
Jason Rosenberg (78)
Gwen Shapira (70)
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 (31)
Jiangjie Qin (29)
Bhavesh Mistry (28)
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