kiwi:受kafka启发的简单消息队列
需积分: 5 41 浏览量
2021-06-04
12:33:21
上传
评论
收藏 44KB ZIP 举报
kiwi-master.zip （60个子文件） 
kiwi-master project 
plugins.sbt 65B assembly.sbt 57B src test scala LogSpec.scala 6KB bytes BinaryFormatIteratorSpec.scala 2KB ChannelBufferByteChunkSpec.scala 2KB FileChannelByteChunkSpec.scala 2KB AwaitableConsumerSpec.scala 1KB KiwiSpec.scala 2KB LogOffsetStorageSpec.scala 1KB resources logback-test.xml 299B main scala bytes ByteChunk.scala 6KB Unsafe.scala 134B AwaitableConsumer.scala 3KB client KiwiClient.scala 1KB ConsoleConsumer.scala 2KB QueueConsumer.scala 3KB benchmark Benchmark.scala 4KB ProducerConsumer.scala 3KB ConsoleProducer.scala 1KB QueueProducer.scala 1KB LogSegment.scala 3KB LogFileRegion.scala 127B Consumer.scala 714B json JsonMessageFormat.scala 1KB io PhiPath.scala 2KB PhiFiles.scala 607B package.scala 376B LogOffsetStorage.scala 5KB Clock.scala 213B benchmark LogBenchmark.scala 1024B Log.scala 5KB message MessageSizeExceedsLimit.scala 99B MessageBatchWithOffset.scala 96B Message.scala 259B MessageBinaryFormat.scala 1KB ByteChunkAndOffset.scala 146B Config.scala 2KB Kiwi.scala 2KB Logger.scala 155B Producer.scala 125B CachedResource.scala 634B server GlobalConsumerFilter.scala 1KB BadRequestService.scala 408B ContentTypes.scala 152B ExceptionHandler.scala 853B OffsetFilter.scala 1KB KiwiServer.scala 2KB RichResponseEncoder.scala 1KB ProducerFilter.scala 1KB RichHttpCodec.scala 1KB BaseConsumerFilter.scala 1KB RichResponse.scala 1KB OffsetConsumerFilter.scala 1KB Exceptions.scala 117B resources reference.conf 212B logback.xml 533B .travis.yml 35B build.sbt 931B README.md 4KB .gitignore 44B资源评论
