没有合适的资源?快使用搜索试试~ 我知道了~
kafka-streams-dotnet:适用于Apache Kafka的.NET流处理库:rocket:
共596个文件
cs:432个
woff:22个
woff2:22个
需积分: 9 0 下载量 130 浏览量
2021-04-18
17:03:03
上传
评论
收藏 12.35MB ZIP 举报
温馨提示
适用于Apache Kafka TM的.NET流处理库· · 质量统计 项目统计 Streamiz Kafka .NET是Apache Kafka的.NET流处理库。 允许开发.NET应用程序,将输入的Kafka主题转换为输出Kafka主题。 支持.NET Standard 2.1。 因此,> = .NET Core 3.0和/或.NET 5.0应用程序可以使用此库。 这是受Kafka Streams启发而进行的重写。 最后,它将提供与Kafka Streams相同的功能。 该项目正在编写中。 感谢您的贡献! 时间线 从2021年开始-1.2.0-永久状态存储(例如:RocksDB存储),分区和Changelog主题 2021年4月-1.3.0-处理器API,指标,交互式查询,备用副本 文献资料 阅读https://lgouellec.github.io/kafka-stre
资源推荐
资源详情
资源评论
收起资源包目录
kafka-streams-dotnet:适用于Apache Kafka的.NET流处理库:rocket: (596个子文件)
streamiz_v1.0.ai 76KB
order_product.avsc 408B
product.avsc 270B
product.avsc 270B
order.avsc 269B
order.avsc 269B
make.bat 962B
.buildinfo 230B
log4net.config 395B
IKStream.cs 129KB
StreamConfig.cs 108KB
IKTable.cs 84KB
StreamBuilder.cs 50KB
StreamConfigTests.cs 38KB
IKGroupedTable.cs 36KB
KStream.cs 34KB
ITimeWindowedKStream.cs 28KB
IKGroupedStream.cs 28KB
KafkaStream.cs 24KB
StreamizMetadataTests.cs 24KB
Materialized.cs 24KB
InternalTopologyBuilder.cs 23KB
MockCluster.cs 22KB
KTable.cs 21KB
KafkaStreamTests.cs 21KB
StreamThread.cs 19KB
TopologyTestDriver.cs 18KB
StreamTableJoinTimestampSynchronizationIntegrationTests.cs 18KB
StreamThreadTests.cs 17KB
SchemaAvroSerDesTests.cs 16KB
TimeWindowKStreamCountTests.cs 15KB
SchemaProtobufSerDesTests.cs 14KB
CustomWindowTests.cs 14KB
TaskMigratedExceptionTests.cs 14KB
InMemoryWindowStore.cs 14KB
TimeWindowKStreamAggTests.cs 13KB
KGroupedTableAggTests.cs 13KB
TimeWindowKStreamReduceTests.cs 13KB
MockSchemaRegistryClient.cs 13KB
KStreamKStreamJoinTests.cs 13KB
KGroupedStreamAggTests.cs 13KB
KStreamKStreamOuterJoinTests.cs 12KB
TopologyDescriptionTests.cs 12KB
StreamJoinProps.cs 12KB
KTableSourceTests.cs 12KB
KGroupedTableReduceTests.cs 12KB
KStreamKStreamLeftJoinTests.cs 11KB
TaskManagerTests.cs 11KB
StreamTask.cs 11KB
KGroupedStreamReduceTests.cs 11KB
KGroupedTableCountTests.cs 11KB
SyncConsumer.cs 11KB
AbstractProcessor.cs 10KB
KTableKTableOuterJoinTests.cs 10KB
StreamTaskTests.cs 10KB
InMemoryWindowStoreTests.cs 10KB
KStreamTableLeftJoinTests.cs 10KB
KStreamPassThoughTests.cs 10KB
KTableKTableLeftJoinTests.cs 9KB
KTableKTableJoinTests.cs 9KB
KGroupedStreamCountTests.cs 9KB
GlobalStreamThread.cs 9KB
TopologyDescription.cs 8KB
KGroupedTable.cs 8KB
RecordCollector.cs 8KB
TaskManager.cs 8KB
TimeWindowedKStream.cs 8KB
StreamJoinBuilder.cs 8KB
TaskSynchronousTopologyDriverTests.cs 8KB
CompositeReadOnlyWindowStoreTests.cs 8KB
GlobalStateManagerTests.cs 7KB
KGroupedStream.cs 7KB
PartitionGrouperTests.cs 7KB
ClusterInMemoryTopologyDriverTests.cs 7KB
TestInputTopic.cs 7KB
MockSchemaRegistryClientTests.cs 7KB
Person.cs 7KB
Order.cs 7KB
TestMultiInputTopic.cs 7KB
DeserializationExceptionHandlerTests.cs 7KB
KStreamTableJoinTests.cs 7KB
MaterializedTests.cs 7KB
MockConsumer.cs 6KB
KTableToStreamTests.cs 6KB
ClusterInMemoryTopologyDriver.cs 6KB
ThreadState.cs 6KB
TestOutputTopic.cs 6KB
GlobalStreamThreadTests.cs 6KB
InternalStreamBuilder.cs 6KB
KStreamFlatMapTests.cs 6KB
PauseResumeTests.cs 5KB
CompositeReadOnlyKeyValueStoreTests.cs 5KB
InMemoryKeyValueStore.cs 5KB
TaskSynchronousTopologyDriver.cs 5KB
WrappedWindowStoreTests.cs 5KB
KTableMapValuesTests.cs 5KB
TableJoinBuilder.cs 5KB
KafkaPipeOutput.cs 5KB
IReadOnlyWindowStore.cs 5KB
SyncProducer.cs 5KB
共 596 条
- 1
- 2
- 3
- 4
- 5
- 6
资源评论
无分别
- 粉丝: 22
- 资源: 4574
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功