文件名称:KafkaAsTable:允许将Apache Kafka主题投影到KeyValue内存表中
文件大小:27KB
文件格式:ZIP
更新时间:2024-03-02 07:45:39
C#
KafkaAsTable 允许将Apache Kafka主题投影到Key / Value内存表中。 支持多分区主题 在初始状态准备就绪时,然后在每个新更新到来时支持通知 例 public record KafkaMessage ( int Key , Guid Value ); private static async Task RunKTableAsync ( string topicName , CancellationToken ct ) { static ( int , Guid ) deserializer ( string message ) { var msg = JsonConvert . DeserializeObject < KafkaMessage>( message ); return ( msg . Key ,
【文件预览】:
KafkaAsTable-main
----src()
--------KafkaAsTable.sln(2KB)
--------ExampleApp()
--------KafkaAsTable()
--------.editorconfig(10KB)
----KTable.png(12KB)
----LICENSE(1KB)
----README.md(4KB)
----.gitignore(185B)