fluent-kafka-streams-tests-master.zip （70个子文件） 
fluent-kafka-streams-tests-master fluent-kafka-streams-tests-junit4 
build.gradle.kts 405B src test resources log4j.properties 373B java com bakdata fluent_kafka_streams_tests junit4 test_applications WordCount.java 2KB WordCountTest.java 9KB WordCountWithDefaultSerdeTest.java 2KB WordCountWithStaticTopologyTest.java 2KB main java com bakdata fluent_kafka_streams_tests junit4 TestTopologyRule.java 5KB gradlew 5KB settings.gradle 401B fluent-kafka-streams-tests build.gradle.kts 857B src test avro Person.avsc 244B City.avsc 246B resources log4j.properties 373B java com bakdata fluent_kafka_streams_tests NameJoinWithIntermediateTopicTest.java 1KB test_applications NameJoinGlobalKTable.java 3KB WordCount.java 2KB CountInhabitantsWithAvro.java 4KB TopicExtractorApplication.java 1KB UserClicksPerMinute.java 3KB ErrorEventsPerMinute.java 4KB ErrorEventsPerMinuteTest.java 12KB NameJoinTest.java 1KB DynamicTopicTest.java 2KB WordCountTest.java 9KB test_types ErrorOutput.java 518B ClickEvent.java 367B StatusCode.java 257B ClickOutput.java 490B WordCountWithDefaultSerdeTest.java 2KB WordCountWithStaticTopologyTest.java 1KB CountInhabitantsWithAvroTest.java 3KB UserClicksPerMinuteTest.java 6KB serde JsonSerde.java 513B JsonSerializer.java 1007B JsonDeserializer.java 1KB main java com bakdata fluent_kafka_streams_tests StreamOutput.java 4KB Expectation.java 4KB TestOutput.java 6KB TableOutput.java 3KB TestInput.java 7KB BaseOutput.java 4KB TestTopology.java 15KB schema-registry-mock-junit4 build.gradle.kts 531B src test java com bakdata schemaregistrymock junit4 SchemaRegistryMockRuleTest.java 6KB main java com bakdata schemaregistrymock junit4 SchemaRegistryMockRule.java 3KB build.gradle.kts 2KB src main javadoc assertj-javadoc.css 14KB schema-registry-mock build.gradle.kts 1KB src test java com bakdata schemaregistrymock SchemaRegistryMockTest.java 12KB main java com bakdata schemaregistrymock SchemaRegistryMock.java 16KB README.md 5KB schema-registry-mock-junit5 build.gradle.kts 656B src test java com bakdata schemaregistrymock junit5 SchemaRegistryMockExtensionTest.java 6KB main java com bakdata schemaregistrymock junit5 SchemaRegistryMockExtension.java 3KB LICENSE 1KB gradle wrapper gradle-wrapper.properties 232B
gradle-wrapper.jar 53KB README.md 7KB gradlew.bat 2KB azure-pipelines.yml 541B gradle.properties 153B fluent-kafka-streams-tests-junit5 build.gradle.kts 530B src test resources log4j.properties 373B java com bakdata fluent_kafka_streams_tests junit5 test_applications WordCount.java 2KB WordCountTest.java 9KB WordCountWithDefaultSerdeTest.java 2KB WordCountWithStaticTopologyTest.java 2KB main java com bakdata fluent_kafka_streams_tests junit5 TestTopologyExtension.java 5KB .gitignore 33B CHANGELOG.md 8KB资源评论
凌冽的风
- 粉丝: 39
- 资源: 4679
最新资源
- 中小学数字化平台解决方案.docx
- 弱电人需要的网络基础知识汇总.docx
- 智慧龙湖天街数字化解决方案.pptx
- 温室大棚、集约养殖、水肥一体、高效节水等设施农业建设方案.docx
- 物流实训室元宇宙解决方案.docx
- 温室大棚、集约养殖、水肥一体、高效节水等设施农业建设方案.pptx
- 农村客货邮融合发展建设方案.docx
- 乡村富民特色产业农业品牌建设方案.pptx
- 农业农村基础设施建设方案.pptx
- 工地数字孪生可视化平台解决方案.pptx
- 基于线性代数与机器学习的实验任务解析-含代码及解答
- 人物检测37-YOLO（v5至v11）、COCO、CreateML、Paligemma、TFRecord、VOC数据集合集.rar
- ANSYS WORKBENCH轴承动力学仿真，ANSYS做内圈、外圈和滚子故障的模拟图片为凯斯西储大学SKF轴承内外圈故障的结果，振动加速度包络后故障特征频率可以与实验相差仅为5%
- 戴尔笔记本Dell 5400 EDC41 - 维修图纸
- matlab实现遗传算法求解迪卡侬生产调度优化问题（含甘特图）-遗传算法-生产调度-Matlab-迪卡侬生产调度优化
- 时变动态分位数CoVaR、delta-CoVaR，分位数回归 △CoVaR测度 溢出效应 动态 Adrian2016基于分位数回归方法计算动态条件在险价值 R语言代码，代码更数据就能用，需要修改的
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
