| clear query|facets|time |
Search criteria: .
Results from 91 to 100 from
489 (0.154s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Offset commit api - Kafka - [mail # dev]
|
|
...Good point about compressed message sets. I think that that works and issimpler. We might still need the txn id to be able to do the application tothe hashmap atomically, but this depends on...
|
|
|
Author: Jay Kreps,
2012-12-18, 16:23
|
|
|
[KAFKA-374] Move to java CRC32 implementation - Kafka - [issue]
|
|
...We keep a per-record crc32. This is fairly cheap algorithm, but the java implementation uses JNI and it seems to be a bit expensive for small records. I have seen this before in Kafka profil...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-374
Author: Jay Kreps,
2012-12-16, 19:42
|
|
|
[KAFKA-673] Broker recovery check logic is reversed - Kafka - [issue]
|
|
...We are currently running recovery when there IS a clean shutdown and not recovering when there isn't....
|
|
|
http://issues.apache.org/jira/browse/KAFKA-673
Author: Jay Kreps,
2012-12-16, 19:12
|
|
|
[KAFKA-616] Implement acks=0 - Kafka - [issue]
|
|
...For completeness it would be nice to handle the case where acks=0 in the produce request. The meaning of this would be that the broker immediately responds without blocking even on the local...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-616
Author: Jay Kreps,
2012-12-14, 14:56
|
|
|
[KAFKA-670] Cleanup spurious .index files if present in the log directory on initialization - Kafka - [issue]
|
|
...It is possible that an index file could somehow be left on the filesystem with no corresponding log file. This is not currently handled well. If the .index file happens to fall on the same o...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-670
Author: Jay Kreps,
2012-12-13, 21:22
|
|
|
[KAFKA-636] Make log segment delete asynchronous - Kafka - [issue]
|
|
...We have a few corner-case bugs around delete of segment files:1. It is possible for delete and truncate to kind of cross streams and end up with a case where you have no segments.2. Reads on...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-636
Author: Jay Kreps,
2012-12-11, 19:47
|
|
|
[KAFKA-667] Rename .highwatermark file - Kafka - [issue]
|
|
...The 0.8 branch currently has a file in each log directory called .highwatermarkSoon we hope to add two more files in the same format. One will hold the cleaner position for log de...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-667
Author: Jay Kreps,
2012-12-11, 19:36
|
|
|
[KAFKA-597] Refactor KafkaScheduler - Kafka - [issue]
|
|
...It would be nice to cleanup KafkaScheduler. Here is what I am thinkingExtract the following interface:trait Scheduler { def startup() def schedule(fun: () => Unit, n...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-597
Author: Jay Kreps,
2012-12-10, 19:31
|
|
|
[KAFKA-559] Garbage collect old consumer metadata entries - Kafka - [issue]
|
|
...Many use cases involve tranient consumers. These consumers create entries under their consumer group in zk and maintain offsets there as well. There is currently no way to delete these entri...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-559
Author: Jay Kreps,
2012-12-06, 17:25
|
|
|
[KAFKA-560] Garbage Collect obsolete topics - Kafka - [issue]
|
|
...Old junk topics tend to accumulate over time. Code may migrate to use new topics leaving the old ones orphaned. Likewise there are some use cases for temporary transient topics. It would be ...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-560
Author: Jay Kreps,
2012-12-06, 17:25
|
|
|
|
