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 171 to 180 from 1811 (0.078s).
Loading phrases to help you
refine your search...
Re: Topic Creation - Kafka - [mail # user]
...Yes, that's the best option for now. The creation is async.Thanks,JunOn Tue, Nov 18, 2014 at 8:55 AM, Bryan Baugher  wrote: ...
   Author: Jun Rao, 2014-11-19, 05:27
Re: Kafka consumer - want to print partition id along with message - Kafka - [mail # user]
...You need to define msg as MessageAndMetadata.Thanks,JunOn Mon, Nov 17, 2014 at 10:43 PM, [EMAIL PROTECTED]LID <[EMAIL PROTECTED]lid> wrote: ...
   Author: Jun Rao, 2014-11-19, 05:24
[expand - 1 more] - Re: Enforcing Network Bandwidth Quote with New Java Producer - Kafka - [mail # user]
...Either is fine. "outgoing-byte-rate" gives you the total and "byte-rate"gives you per topic.Thanks,JunOn Mon, Nov 17, 2014 at 3:58 PM, Bhavesh Mistry wrote: ...
   Author: Jun Rao, 2014-11-19, 05:12
Re: kafka application logdir - Kafka - [mail # user]
...Try the following.KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:/mylog4jdir"/opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.propertiesThanks,JunOn Mon, Nov 17, 2014 at 11:11 AM,...
   Author: Jun Rao, 2014-11-19, 05:00
[KAFKA-1743] ConsumerConnector.commitOffsets in 0.8.2 is not backward compatible - Kafka - [issue]
...In 0.8.1.x, ConsumerConnector has the following api:  def commitOffsetsThis is changed to the following in 0.8.2 and breaks compatibility  def commitOffsets(retryOnFailur...
http://issues.apache.org/jira/browse/KAFKA-1743    Author: Jun Rao, 2014-11-19, 03:04
[expand - 3 more] - Re: Getting Simple consumer details using MBean - Kafka - [mail # user]
...If you connect to the jvm of the consumer, you will see the following mbean."kafka.consumer":type="FetchRequestAndResponseMetrics",name="SimpleConsumerShell-AllBrokersFetchRequestRateAndTime...
   Author: Jun Rao, 2014-11-19, 00:15
[KAFKA-1769] javadoc should only include client facing packages - Kafka - [issue]
http://issues.apache.org/jira/browse/KAFKA-1769    Author: Jun Rao, 2014-11-18, 02:53
Re: shrinking isr for partitions followed by error.. (kafka 0.8.1.1) - Kafka - [mail # user]
...We fixed a bunch of issues related to delete topic in 0.8.2. Could you trythe 0.8.2 beta release?Thanks,JunOn Fri, Nov 14, 2014 at 5:04 PM, Manish  wrote: ...
   Author: Jun Rao, 2014-11-18, 02:47
[expand - 1 more] - Re: Location of Logging Files/How To Turn On Logging For Kafka Components - Kafka - [mail # user]
...You need to set the location of log4j.properties in a JVM variable. Take alook at the kafka scripts in bin/Thanks,JunOn Thu, Nov 13, 2014 at 10:53 PM, Alex Melville  wrote: ...
   Author: Jun Rao, 2014-11-14, 22:50
Re: Kafka to transport binary files - Kafka - [mail # user]
...Both the Kafka client and broker need to allocate memory for the wholemessage. So, the larger the message, the more memory fragmentation it maycause, which can lead to GC/OOME issues.Thanks,...
   Author: Jun Rao, 2014-11-14, 01:36
Sort:
project
Kafka (1811)
Cassandra (27)
Zookeeper (17)
Avro (6)
Hadoop (3)
type
mail # user (1238)
mail # dev (294)
issue (279)
date
last 7 days (33)
last 30 days (66)
last 90 days (153)
last 6 months (290)
last 9 months (1811)
author
Jun Rao (1057)
Neha Narkhede (570)
Neha Narkhede (412)
Jay Kreps (352)
Guozhang Wang (288)
Jun Rao (276)
Joe Stein (251)
Joel Koshy (194)
John Fung (95)
Joe Stein (94)
Jay Kreps (89)
Guozhang Wang (88)
Jason Rosenberg (78)
Gwen Shapira (65)
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 (30)
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