kafka技术内幕源码.zip
需积分: 10 150 浏览量
2018-02-10
22:20:49
上传
评论
收藏 2.8MB ZIP 举报
kafka技术内幕源码.zip （472个子文件） 
global-tables-example.avsc 1KB order.avsc 959B ordervalidation.avsc 671B LogLine.avsc 374B customer.avsc 352B song.avsc 329B pageview.avsc 315B payment.avsc 302B pageviewstats.avsc 291B wikifeed.avsc 257B pageviewregion.avsc 253B userprofile.avsc 220B songplaycount.avsc 207B playevent.avsc 205B application.conf 1KB kafka_client_jaas.conf 126B config 306B description 73B exclude 240B .gitignore 73B producer.go 853B consumer.go 818B HEAD 182B HEAD 182B HEAD 32B HEAD 23B pack-161c93714a1f09857bd043645c200aa8b9f34507.idx 30KB index 69KB StreamStatefulDemo.java 25KB KafkaMusicExample.java 22KB OrdersService.java 15KB NFATest.java 15KB NFA.java 15KB KafkaMusicExampleTest.java 14KB LogLine.java 13KB EventDeduplicationLambdaIntegrationTest.java 13KB PageViewRegionExample.java 13KB IntegrationTestUtils.java 13KB StreamStatelessDemo.java 12KB CEPProcessor.java 12KB Producer.java 12KB TopArticlesLambdaExample.java 12KB StreamToTableJoinIntegrationTest.java 12KB WordCountInteractiveQueriesExampleTest.java 12KB PageViewRegionLambdaExample.java 12KB GlobalKTablesExample.java 11KB WordCountInteractiveQueriesExample.java 11KB SecureKafkaStreamsExample.java 11KB WordCountLambdaExample.java 10KB TransactionProducer.java 10KB WordCountInteractiveQueriesRestService.java 10KB Consumer.java 9KB SessionWindowsExampleTest.java 9KB SessionWindowsExample.java 9KB StateStoresInTheDSLIntegrationTest.java 9KB AnomalyDetectionLambdaExample.java 9KB GlobalKTablesExampleDriver.java 9KB MusicPlaysRestService.java 9KB LowLevelConsumerExample.java 9KB PageViewTypedDemo.java 9KB UserRegionLambdaExample.java 9KB MicroserviceTestUtils.java 9KB TableToTableJoinIntegrationTest.java 9KB MapFunctionLambdaExample.java 9KB ApplicationResetExample.java 9KB KafkaMusicExampleDriver.java 9KB WikipediaFeedAvroExample.java 8KB SessionWindowsExampleDriver.java 8KB MixAndMatchLambdaIntegrationTest.java 8KB StreamToStreamJoinIntegrationTest.java 8KB KVSharedVersionedBuffer.java 8KB UserCountsPerRegionLambdaIntegrationTest.java 8KB WikipediaStreamDemo.java 8KB WikipediaFeedAvroLambdaExample.java 8KB SumLambdaExample.java 8KB HandlingCorruptedInputRecordsIntegrationTest.java 7KB Handler.java 7KB MicroserviceUtils.java 7KB KafkaEmbedded.java 7KB GlobalKTablesExampleTest.java 7KB KafkaDisruptor.java 7KB OrdersServiceTest.java 7KB EmbeddedSingleNodeKafkaCluster.java 7KB GenericAvroIntegrationTest.java 7KB OrderDetailsService.java 7KB WordCountLambdaIntegrationTest.java 7KB CassClient.java 7KB InventoryService.java 7KB SpecificAvroIntegrationTest.java 7KB ValidateStateWithInteractiveQueriesLambdaIntegrationTest.java 7KB TopArticlesExampleDriver.java 6KB TopArticlesLambdaExampleTest.java 6KB FanoutLambdaIntegrationTest.java 6KB PageViewUntypedDemo.java 6KB EndToEndTest.java 6KB ApplicationResetIntegrationTest.java 6KB Stage.java 6KB ConnectEmbedded.java 6KB PageViewRegionExampleDriver.java 6KB Producer.java 6KB共 472 条
- 1
- 2
- 3
- 4
- 5
资源评论
