| clear query|facets|time |
Search criteria: .
Results from 121 to 130 from
490 (0.141s).
|
|
|
Loading phrases to help you
refine your search...
|
|
HighwaterMarkCheckpoint - Kafka - [mail # dev]
|
|
...The api for the HighwaterMarkCheckpoint is: def write(highwaterMarksPerPartition: Map[TopicAndPartition, Long]) def read(topic: String, partition: Int): Long ...
|
|
|
Author: Jay Kreps,
2012-11-27, 00:14
|
|
|
AdminTest is failing on 0.8 - Kafka - [mail # dev]
|
|
...AdminTest.testShutdownBroker is consistently failing since a few checkins ago. I couldn't figure it out but I am pretty sure I didn't cause it... [0m[#27;[31merror#27;[0m] #27;[0mTest ...
|
|
|
Author: Jay Kreps,
2012-11-26, 21:03
|
|
|
Re: understanding partitions based on wiki example of profile visits - Kafka - [mail # dev]
|
|
...Yeah a partition is physically implemented as a log (i.e. a sequence of files containing a bunch of messages indexed by offset). So each server can have lots of partitions, but each partitio...
|
|
|
Author: Jay Kreps,
2012-11-26, 19:02
|
|
|
Re: understanding partitions based on wiki example of profile visits - Kafka - [mail # dev]
|
|
...Yes, your description is correct. A particular member's data would all be in one partition. Broker partitions are just the unit of parallelism--think of each partition as a totally ord...
|
|
|
Author: Jay Kreps,
2012-11-26, 16:53
|
|
|
[KAFKA-367] StringEncoder/StringDecoder use platform default character set - Kafka - [issue]
|
|
...StringEncoder and StringDecoder take the platform default character set. This is bad since the messages they produce are sent off that machine. We should-- add a new required argument to the...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-367
Author: Jay Kreps,
2012-11-22, 22:03
|
|
|
Re: dumb question about offsets - Kafka - [mail # user]
|
|
...Hi Philip, Yes, the offset idea is critical--offsets remain in 0.8. Offset is still both the primary key and also the logical idea of time in the log, it is just that now the translati...
|
|
|
Author: Jay Kreps,
2012-11-22, 21:54
|
|
|
Fwd: ASF Board Meeting Summary - November 21, 2012 - Kafka - [mail # dev]
|
|
...We graduated! -Jay From: Doug Cutting Date: Wed, Nov 21, 2012 at 1:45 PM Subject: ASF Board Meeting Summary - November 21, 2012 To: [EMAIL PROTECTED] The November board me...
|
|
|
Author: Jay Kreps,
2012-11-21, 22:14
|
|
|
Re: Kafka + Maven - Kafka - [mail # user]
|
|
...Thanks for the feedback everyone. I do want to mention that the lack of action on this is not because we don't care. Most all the committers have been almost entirely heads down on get...
|
|
|
Author: Jay Kreps,
2012-11-21, 16:52
|
|
|
Re: Thread Safety of KafkaStreams - Kafka - [mail # user]
|
|
...The partitions are ordered (in publication order) so there isn't an easy way to split a single partition up amongst threads without breaking this, which is the reason the consumer works that...
|
|
|
Author: Jay Kreps,
2012-11-21, 15:56
|
|
|
Re: Build failed in Jenkins: Kafka-0.8 #113 - Kafka - [mail # dev]
|
|
...Hey Jun, I think AdminTest.testShutdownBroker started failing consistently after this checkin. -Jay On Sun, Nov 18, 2012 at 10:09 PM, Apache Jenkins Server wrote: &n...
|
|
|
Author: Jay Kreps,
2012-11-21, 04:29
|
|
|
|
