文件名称：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)