| clear query|facets|time |
Search criteria: .
Results from 31 to 40 from
124 (0.249s).
|
|
|
Loading phrases to help you refine your search...
|
|
Re: log.file.size limit? - Kafka - [mail # user]
|
|
...If you look at the description of the "map" method, it states:size - The size of the region to be mapped; must be non-negative and no greater than Integer.MAX_VALUE-DavidOn 3/25/13 4:37 PM, ...
|
|
|
Author: David Arthur,
2013-03-25, 23:21
|
|
|
Re: log.file.size limit? - Kafka - [mail # user]
|
|
...FileChannel#map docs indicate the max size is Integer.MAX_VALUE, so yea 2gbhttp://docs.oracle.com/javase/6/docs/api/java/nio/channels/FileChannel.html#map(java.nio.channels.FileChannel.MapMo...
|
|
|
Author: David Arthur,
2013-03-25, 19:14
|
|
|
Re: Consume from X messages ago - Kafka - [mail # user]
|
|
...This API is exposed through the SimpleConsumer scala class. See https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala#L60You will need to set ear...
|
|
|
Author: David Arthur,
2013-03-19, 15:49
|
|
|
Re: Consume from X messages ago - Kafka - [mail # user]
|
|
...Using the Offsets API, you can get the latest offset by setting time to -1. Then you subtract 10000There is no guarantee that 10k prior messages exist of course, so you'd need to handle that...
|
|
|
Author: David Arthur,
2013-03-19, 15:17
|
|
|
Anyone working on a Kafka book? - Kafka - [mail # dev]
|
|
...I was approached by a publisher the other day to do a book on Kafka - something I've actually thought about pursuing. Before I say yes (or consider saying yes), I wanted to make sure no one ...
|
|
|
Author: David Arthur,
2013-03-19, 13:35
|
|
|
Re: Is anyone able to consume from Kafka 0.7.x and write into Hadoop CDH 4.x ? - Kafka - [mail # user]
|
|
...I have used KafkaETLJob to write a job that consumes from Kafka and writes to HDFS. Kafka version 0.7.2 rc5 and CDH 4.1.2.Is anything in particular not working?-DavidOn 3/14/13 5:31 PM, Matt...
|
|
|
Author: David Arthur,
2013-03-15, 03:29
|
|
|
Re: Topic config zk structures - Kafka - [mail # dev]
|
|
...I'd vote for everything being JSON, for consistencyOn 3/7/13 1:10 PM, Jay Kreps wrote:> I added a proposal to the ZK data structures wiki under the heading> 0.8.1 covering my proposal ...
|
|
|
Author: David Arthur,
2013-03-11, 21:03
|
|
|
[KAFKA-759] Commit/FetchOffset APIs should not return versionId - Kafka - [issue]
|
|
|
|
http://issues.apache.org/jira/browse/KAFKA-759
Author: David Arthur,
2013-03-01, 21:54
|
|
|
[KAFKA-771] NPE in handleOffsetCommitRequest - Kafka - [issue]
|
|
...If the metadata string is null, we get an NPE on the length check...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-771
Author: David Arthur,
2013-02-25, 02:11
|
|
|
0.8 build problems - Kafka - [mail # dev]
|
|
...I'm having trouble building the project with sbt, specifically I am unable to run package and have the kafka-server-start.sh script workgit clone git://github.com/apache/kafka.git./sbt updat...
|
|
|
Author: David Arthur,
2013-02-21, 22:41
|
|
|
|